Kafka集群安装配置

Kafka集群安装配置

kafka的使用需要先安装scala环境。

1、下载解压scala，并配置环境变量。

export SCALA_HOME=/home/scala export PATH=$SCALA_HOME/bin:$PATH

执行source /etc/profile使配置生效。

查看scala版本：

scala -version

在所有的slave节点进行如上配置。

2、下载解压kafka，这次不用配置环境变量。

3、进入kafka/config目录,编辑server.properties,对如下项进行修改：

#表示集群中broker唯一id broker.id=0 #zookeeper集群配置 zookeeper.connect=192.168.168.133:2181,192.168.168.134:2181,192.168.168.135:2181

4、将scp拷贝到所有的slave节点。

scp -r /home/kafka root@k8s-node1:/home scp -r /home/kafka root@k8s-node2:/home

将每个slave中的broker.id依次增加1,2…

5、进入kafka目录，分别在所有节点执行如下命令：

#进程后台执行 nohup bin/kafka-serer-start.sh config/server.properties &

6、jps查看，发现kafka，启动成功。

如果启动未成功，在kafka目录下会有错误日志。

我在启动时出现.lock 正在被tmp/kafka-logs（记不太清了）占据的错误，删掉tmp/kafka-logs并重启kafka就行了，遇到其他问题再和大家分享。