前提條件：本人啟動了本地啟動三台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集群可用。