实验过程

1.三个虚拟机中解压kafka软件包

tar -zxvf kafka_2.11-1.1.1.tgz

2.修改 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