我有一个主题汽车,只有 1 个分区和 1 个复制因子,如下所示:
Topic:cars PartitionCount:1 ReplicationFactor:1 Configs:
Topic: cars Partition: 0 Leader: 0 Replicas: 0 Isr: 0
我有两个经纪人在运行,一个在 9092 上,另一个在我的本地主机上的 9093 上。
我的 java 应用程序向主题汽车发送消息。我看到一个非常奇怪的行为。
- 我的 Java 应用程序只接收备用消息,例如消息 #1、消息 #3.. 等等
为了调试这个问题,我启动了一个控制台消费者。现在我只能看到我的 java 应用程序没有收到的那些消息。例如,消息 #2、消息 #4 .. 等等
很明显,我的消息已正确发布到主题,那么,是什么导致我的 java 应用程序只接收备用消息?
最后,为什么消费者控制台只展示上述行为?