前提条件：本人启动了本地启动三台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集群可用。