共采用三台虚拟机来组成kafka集群
先找到kafka的安装目录
cd /usr/local/kafka
进入config目录,修改server.properties
cd config/
vim server.properties
主要修改三处配置
按 i 进入编辑模式,/进行搜索,n搜索的下一项,N搜索的上一项
第一个是broker.id,需要保证集群中每一个节点的id唯一
第二个是isteners=PLAINTEXT://192.168.158.139:9092,这里的ip就是你的虚拟机ip
zookeeper.connect=192.168.158.139:2181,这里是你的zookeeper的地址,三个服务器需要保持一致,这里采用kafka第一个节点自带的zookeeper
配置完成后,esc退出编辑模式,wq强制保存
进入bin 目录 cd bin/
先启动第一个节点的kafka自带的zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
然后依次启动三个kafka节点
./bin/kafka-server-start.sh ./config/server.properties
启动完成后,新建一个topic测试
./kafka-topics.sh --create --bootstrap-server 192.168.158.139:9092 --replication-factor 3 --partitions 3 --topic test
查看创建的topic
./kafka-topics.sh --bootstrap-server 192.168.158.139:9092 --list