-
在搭建kafka的集群环境之前,需要把zookeeper的集群环境搭建好。
-
解压kafka安装包后,进入编辑kafka/config/server.properties配置文件。 在最后加入zookeeper服务的ip地址映射连接
在192.168.241.20这台机子节点上:
broker.id=0 listeners=PLAINTEXT://192.168.241.20:9092 zookeeper.connect=192.168.241.20:2181,192.168.241.21:2181,192.168.241.22:2181
在192.168.241.21这台机子节点上:
broker.id=1 listeners=PLAINTEXT://192.168.241.21:9092 zookeeper.connect=192.168.241.20:2181,192.168.241.21:2181,192.168.241.22:2181
在192.168.241.22这台机子节点上:
broker.id=2 listeners=PLAINTEXT://192.168.241.22:9092 zookeeper.connect=192.168.241.20:2181,192.168.241.21:2181,192.168.241.22:2181
-
记得在~/.bashrc环境变量中把kafka的路径配置进去:(所有机器节点都要)
export KAFKA_HOME=/usr/local/src/kafka_2.11-0.10.2.1 export PATH=$PATH:$KAFKA_HOME/bin
通过 source ~/.bashrc使环境变量立即生效
-
记得先将超过一半的机子节点的zookeeper先启动: zkServer.sh start, 并通过zkServer.sh status查看状态。
-
再在后台启动kafka集群:(所有的机器节点都要)
./kafka/bin/kafka-server-start.sh -daemon ../config/server.properties
-
执行完zookeeper和kafka启动命令后,通过jps检查进程是否有启动: zookeeper的进程是:QuorumPeerMain kafka的进程是:kafka