CentOS7安装kafka集群

一、前提条件

• jdk1.7以上
• zookeeper配置
• kafka节点配置

二、kafka配置

• kafka1 192.168.10.45
• kafka2 192.168.10.78
• kafka2 192.168.10.217

2.1 server.properties 配置

[kafka@xiangys0134-docker-01 ~]cd /usr/local/kafka_2.11-2.3.1/config/
[kafka@xiangys0134-docker-01 config] vim server.properties     //添加zk
broker.id=0                             //id必须唯一
listeners=PLAINTEXT://192.168.10.45:9092
localhost:2181,192.168.10.78:2181,192.168.10.217:2181

2.2重启kafka

[root@localhost tmp]# su - kafka -c 'nohup /usr/local/kafka_2.11-2.3.1/bin/kafka-server-start.sh /usr/local/kafka_2.11-2.3.1/config/server.properties &'

三、 测试消息

3.1 master上创建topic

[zk@xiangys0134-docker-01 bin]$ ./kafka-topics.sh --create --zookeeper 192.168.10.45:2181,192.168.10.78:2181,192.168.10.217:2181 --replication-factor 3 --partitions 3 --topic test1234
Created topic test1234.

3.2 显示topic信息

[kafka@localhost bin]$ ./kafka-topics.sh --describe --zookeeper 192.168.10.45:2181,192.168.10.78:2181,192.168.10.217:2181 --topic test1234

3.3 列出topic

[kafka@localhost bin]$ ./kafka-topics.sh --list --zookeeper 192.168.10.45:2181,192.168.10.78:2181,192.168.10.217:2181

3.4在kafka-1生产消息

[zk@xiangys0134-docker-01 bin]$ ./kafka-console-producer.sh --broker-list 192.168.10.45:9092 -topic test1234

3.5在kafka2接收消息

[kafka@localhost bin]$ ./kafka-console-consumer.sh --bootstrap-server 192.168.10.78:9092 -topic test1234 --from-beginning

3.6删除topic

[kafka@localhost bin]$ ./kafka-topics.sh --delete --zookeeper 192.168.10.45:2181,192.168.10.78:2181,192.168.10.217:2181 --topic test1234

备注：在由topic生产消息和消费消息时就无法进行删除，不知道怎么回事

四、 停止服务

停止时，需先依次停止kafka，再停止zookeeper