如何测试kafka集群能否正常工作？
1.查看具体的程序是否启动
ps -ef |grep java
2.发布一条消息
随机登录一台机器，进入kafka安装程序的bin文件夹中
cd /opt/test/kafka_2.12-2.6.3/bin 创建主题 ./kafka-topics.sh --create --zookeeper 192.168.1.20:2181 --topic test --partitions 3 --replication-factor 1 #这个命令是否正确没有验证，只是做了结果验证
向主题中写入内容
./kafka-console-producer.sh --broker-list 192.168.1.20:9092,192.168.1.21:9092,192.168.1.22:9092 --topic test
CTRL+D 退出来
3.订阅消息
随机登录一台机器，进入kafka安装程序的bin文件夹中
cd /opt/test/kafka_2.12-2.6.3/bin ./kafka-console-consumer.sh --bootstrap-server 192.168.1.21:9092 --topic test --from-beginning
