实验过程
1.三个虚拟机中解压kafka软件包
tar -zxvf kafka_2.11-1.1.1.tgz2.修改 3 个节点配置文件
在 zookeeper 节点，进入 kafka_2.11-1.1.1/config 目录下，编辑 server.properties 文件
[root@db1 ~]# cd kafka_2.11-1.1.1/config
[root@db1 config]# vi server.properties
修改：
broker.id=1
zookeeper.connect=192.168.224.3:2181,192.168.224.4:2181,192.168.224.5:2181
listeners = PLAINTEXT://192.168.224.3:9092
[root@db2 ~]# cd kafka_2.11-1.1.1/config
[root@db2 config]# vi server.properties
修改：
broker.id=2
zookeeper.connect=192.168.224.3:2181,192.168.224.4:2181,192.168.224.5:2181
listeners = PLAINTEXT://192.168.224.4:9092
[root@mycat ~]# cd kafka_2.11-1.1.1/config
[root@mycat config]# vi server.properties
修改：
broker.id=3
zookeeper.connect=192.168.224.3:2181,192.168.224.4:2181,192.168.224.5:2181
listeners = PLAINTEXT://192.168.224.5:9092
3.启动服务
在 zookeeper1 节点，进入 kafka_2.11-1.1.1/bin 目录下
[root@db1 ~]# cd kafka_2.11-1.1.1/bin
[root@db1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[root@db1 bin]# jps
[root@db1 bin]# ./kafka-topics.sh --create --zookeeper 192.168.224.3:2181 --replication-factor 1 --partitions 1 --topic test 
[root@db2 ~]# cd kafka_2.11-1.1.1/bin
[root@db2 bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[root@db2 bin]# jps
[root@db2 bin]# ./kafka-topics.sh --list --zookeeper 192.168.224.4:2181
[root@mycat ~]# cd kafka_2.11-1.1.1/bin
[root@mycat bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[root@mycat bin]# jps
[root@mycat bin]# ./kafka-topics.sh --list --zookeeper 192.168.224.5:2181
原文地址:https://blog.csdn.net/2301_79757379/article/details/135631189
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.7code.cn/show_57426.html
如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！
