apache-kafka - 为什么写入和读取 Kafka 队列之间存在延迟？

Question

我编写了一个工作服务来使用来自 Kafka 队列的消息，并且我还编写了一个测试脚本来每隔几秒钟将消息添加到队列中。

我注意到的是，当消息被添加到队列中时，消费者通常会一次闲置几分钟。然后突然消费者会拿起第一条消息，处理它，然后迅速转移到其余部分。所以它最终赶上了，但我想知道为什么首先会有这样的延迟？

Answer 1

在延迟期间，消费者组将花费一些时间联系组协调员并自动获得分配的分区。

如果您使用手动分配，您将获得更少的延迟。