1. 在窗口1创建一个producer，topic为test，broker-list为zookeeper集群ip+端口
/usr/local/kafka/bin/kafka-console-producer.sh --broker-list 127.0.0.1:9091,127.0.0.1:9092,127.0.0.1:9093 --topic test
2.在窗口2创建一个consumer，topic为test，bootstrap-server为zookeeper集群ip+端口
/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9091,127.0.0.1:9092,127.0.0.1:9093 --topic test --from-beginning
3.zookeeper客户端启动
/usr/local/zookeeper/bin/zkCli.sh -server 10.10.10.188:2182,10.10.10.188:2183,10.10.10.188:2184
10.10.10.188:9091,127.0.0.1,10.10.10.188:9092,10.10.10.188:9093
kafka-消费者测试
原文：https://www.cnblogs.com/brady-wang/p/13741987.html
