kafka+zookeeper集群搭建

请参照此文章搭建

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集群中的任意一个节点

相关推荐