kafka-消费者测试

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 
原文地址:https://www.cnblogs.com/brady-wang/p/13741987.html