我从 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
所以……我哪里做错了?帮助将不胜感激。谢谢!