关于kafka新版本的一个问题

Question

因为公司版本要求，就下了2.0的kafka，然后发现了kafka在使用消费者的命令的时候用的是：kafka-console-consumer.sh --bootstrap-server 172.16.146.188:9092 --topic hello_topic --from-beginning 把原本的zookeeper:2181换成了–bootstrap-server 172.16.146.188:9092；在单个broker上面是可以正常运行的；但是在broker的三个副本情况下即：

kafka-topics.sh --create --zookeeper 172.16.146.188:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
kafka-console-producer.sh --broker-list 172.16.146.188:9093,172.16.146.188:9094,172.16.146.188:9095 --topic my-replicated-topic

启动了三个broker的消费者的脚本后，再输入kafka-console-consumer.sh --bootstrap-server 172.16.146.188:9093,172.16.146.188:9094,172.16.146.188:9095 --topic my-replicated-topic --from-beginning，但是我在生产者的command上输入内容在消费者的command面板缺显示不出来，，就不太知道2.0版本，就是消费者把zookeeper换成了bootstrap-server hostname:port之后怎么用呢？？单个broker是没有问题的，多个就出现了问题，日志也没有报错，我看了2.0的官方文档也是只举了当个broker的例子

Answer 1

Michael_PK 2020-03-02 00:30:47

这个2.x的版本我没有测试过，不是太清楚具体的东西。我们生产没有使用这么高的。需要你自己去调研下呢

• 提问者 KelvinChung #1

  请问pk哥现在生产上也是0.9版本的吗

• Michael_PK 回复 提问者 KelvinChung #2

  0.9，1.0都有

Answer 2

慕丝1189759 2020-07-19 16:31:10

我用的是2.12的kafka， 如果consumer的命令加上 --partition 0 可以接收到消息，如果不加只有--bootstrap-server指定为broker.id=0的端口才能接收到消息

Answer 3

慕田峪7198936 2020-06-19 03:51:20

同学，我现在也遇到了这个问题，请问你解决了吗