前提条件：本人启动了本地启动三台cenos6.5虚拟机192.168.25.128，192.168.25.133，192.168.25.153。
且关闭防火墙，保证三台机器能相互通信。
已在这三台机器上搭建kafka_2.12-2.4.0版本的kafka集群，和zookeeper-3.4.6版本的zookeeper集群，
配置了1.8版本的java环境。
下面介绍如何进行测试kafka集群能否正常工作
1.先用ps命令查看是否有 kafka和zookeeper相关的进程
ps -ef |grep java
2.发布消息
随机登录一台机器，进入kafka安装程序的bin文件夹中
cd /root/apps/kafka_2.12-2.4.0/bin
创建主题
./kafka-topics.sh --create --zookeeper 192.168.25.128:2181,192.168.25.133:2181,192.168.25.153:2181 --topic test --partitions 3 --replication-factor 1
向主题中写入内容
./kafka-console-producer.sh --broker-list 192.168.25.128:9092,192.168.25.133:9092,192.168.25.153:9092 --topic test
CTRL+D结束写入内容
3.订阅消息
随机登录一台机器，进入kafka安装程序的bin文件夹中
cd /root/apps/kafka_2.12-2.4.0/bin
消费消息
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
CTRL+C结束消费
自此可证明搭建的kafka集群可用。