我已经编写了一个worker服务来使用kafka队列中的消息，并且还编写了一个测试脚本来每隔几秒钟将消息添加到队列中。我注意到，当消息被添加到队列中时，消费者通常会一次空闲几分钟。然后，消费者会突然拿起第一条消息，对其进行处理，然后迅速转到其他消息。所以它终于赶上了，但我想知道为什么一开始会有这样的延迟？
mutmk8jj1#
用户组将需要一些时间来联系组协调员，并在延迟期间自动获得分配的分区。如果你使用手动分配，你会得到更少的延迟。
1条答案
按热度按时间mutmk8jj1#
用户组将需要一些时间来联系组协调员，并在延迟期间自动获得分配的分区。
如果你使用手动分配，你会得到更少的延迟。