如何测试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
复制