Kafka Java使用者不使用来自特定分区的消息

Question

我创建了一个具有5个分区和3个复制因子的主题。我有两个消费者应用程序正在运行，都属于不同的消费者群体。 我有一位制作人正在制作关于这个话题的信息。下面是该主题的分区、领导者和副本状态的屏幕截图。min.insync。副本具有默认配置。

最初，两个消费者都在消费来自所有分区的消息，但一段时间后，消息只会被消费来自分区2。 如果我清除主题并再次创建，所有分区中的消息都将被消耗。 我经常面临这个问题