iamdll 2019-05-27
请参照此文章搭建
https://www.cnblogs.com/saneri/p/8762168.html
注意,上面的博客不是高版本kafka,高版本的kafka不在支持zookeeper参数了,如下面这个例子
./kafka-console-consumer.sh --zookeeper 192.168.43.117:2188, 192.168.43.31:2188, 192.168.43.60:2188 --topic test --from-beginning
应该改为:
./kafka-console-consumer.sh --bootstrap-server 192.168.43.117:9099 --topic test --from-beginning
这个192.168.43.117:9099是kafka集群中的任意一个节点