Kafka 2.12 Consumer Group (with command prompt) - Second consumer can't seem to receive the message?

问题描述 投票:0回答:0

我从 Apache Kafka 2.12 开始,在使用命令提示符时练习消费者组时遇到了问题:当创建两个消费者并设置为订阅组中的一个主题时,似乎只有一个消费者收到所有这条消息,另一个消费者什么也没收到。

所以,在运行 Zookeeper 和 Kafka 服务器之后(假设我们重新开始),这就是我在第三个命令提示符下输入的内容来创建主题:

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 2 --topic test-TOPIC

接下来,我打开第 4 个命令提示符并输入:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-TOPIC --group learning

最后,我打开第 5 个命令提示符并输入:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-TOPIC --group learning

现在我回到第三个命令提示符并开始输入这些消息(用新行分隔):

One
Two
Three
Four
Five
Six

但是只有第 5 个命令提示符会收到消息。第 4 个命令提示符什么也没有。从我在网上看到的教程(我可以告诉你,但我不确定它是否合乎道德,而且它是印度尼西亚语,所以......还没有),它按计划工作,产生了这个结果:

第五个命令提示符得到:

One
Three
Five

第四个命令提示符得到:

Two
Four
Six

所以……我哪里做错了?帮助将不胜感激。谢谢!

apache-kafka kafka-consumer-api
© www.soinside.com 2019 - 2024. All rights reserved.