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