关于kafka新版本的一个问题

来源：4-6 -Kafka单节点多broker部署及使用

KelvinChung

2020-03-01

因为公司版本要求，就下了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的例子

写回答

3回答