kafka订户只获取备用消息

xn1cxnb4  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(209)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题