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

clj7thdc 于 2021-06-07 发布在 Kafka

关注(0)|答案(16)|浏览(458)

我正在为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 consumer时，它通过运行

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从控制台使用者订阅主题？我该怎么修？

16条答案

复制因子必须至少为3

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