apache-kafka - 偏移提交在 kafka 0.10.2.2 中失败

Question

我使用的是 kafka-client 版本 0.10.2.2，总共有 10 个 kafka 消费者线程。在重新平衡期间，4/10 成功加入了该组，在其余 6 个线程上，我收到以下日志：

• 将组 [xyz] 的协调器标记为死亡。
• 发现组 [xyz] 的协调员。这 6 个线程从未加入该组，它们仍在处理消息，但它们的偏移提交失败。有没有人也遇到过类似的问题？

标签： apache-kafkakafka-consumer-api