消费者未接收消息，kafka控制台，新的消费者api，kafka 0.9

Question

我正在为Kafka0.9.0.0做Kafka快速入门。

我让zookeeper在localhost:2181监听，因为我运行了

bin/zookeeper-server-start.sh config/zookeeper.properties

只有一个代理在localhost:9092处侦听，因为我运行了

bin/kafka-server-start.sh config/server.properties

我有一个制作人在主题“测试”上发帖，因为我跑了

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
yello
is this thing on?
let's try another
gimme more

当我运行旧的API使用者时，它通过运行

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

但是，当我运行新的API使用者时，我在运行时没有得到任何东西

bin/kafka-console-consumer.sh --new-consumer --topic test --from-beginning \
    --bootstrap-server localhost:9092

是否可以使用新的API从控制台使用者订阅主题？我该怎么修好它？

Answer 1

我的MAC box也面临着同样的问题：控制台使用者在使用该命令时不使用任何消息

kafka-console-consumer --bootstrap-server localhost:9095 --from-beginning --topic my-replicated-topic

但当我试着

kafka-console-consumer --bootstrap-server localhost:9095 --from-beginning --topic my-replicated-topic --partition 0

它高兴地列出了发送的消息。这是卡夫卡1.10.11中的bug吗？