当消费者的处理时间超过max.poll.interval.ms时，消费者未停机

Question

我试图做一个简单的poc与Spring启动与版本（2.3.7发布）的SpringKafka，以实现消费者批处理的工作原理，以及如何再平衡工作，如果消费者需要更多的流转时长，因为我是全新的这个消息系统。

现在我看到kafka重新平衡单个消费者（不允许并发）的问题。

这些是我设置的max.poll.interval属性。ms=50000和factory.getContanerProperties。setIdealTimeBetweenPolls（120000）并使消费者批处理过程花费的时间超过此max.poll.interval.ms。根据我的理解，实际上这不应该发生。只有第一次再平衡才会发生。

我遗漏了什么吗？

Answer 1

是的，如果超过< code > max . poll . interval . ms ，就会发生重新平衡——代理认为您的消费者已经死了，所以收回分区(即使不再有消费者)。

当你下次投票时，重新平衡发生了，因为你只有一个消费者，他再次得到所有8个分区。