为什么写入和读取 Kafka 队列之间存在延迟？
Why is there a delay between writing to and reading from Kafka queue?
我写了一个工作服务来消费来自 Kafka 队列的消息，我还写了一个测试脚本每隔几秒就向队列添加消息。
我注意到，当消息被添加到队列中时，消费者通常会一次闲置几分钟。然后消费者会突然拿起第一条消息，处理它，然后迅速转移到其余部分。所以它最终赶上了，但我想知道为什么一开始会有这样的延迟？
Consumer group 需要一些时间联系 group coordinator 并在延迟期间自动获得分配的分区。
如果您使用手动分配，您将获得更少的延迟。
我写了一个工作服务来消费来自 Kafka 队列的消息，我还写了一个测试脚本每隔几秒就向队列添加消息。
我注意到，当消息被添加到队列中时，消费者通常会一次闲置几分钟。然后消费者会突然拿起第一条消息，处理它，然后迅速转移到其余部分。所以它最终赶上了，但我想知道为什么一开始会有这样的延迟？
Consumer group 需要一些时间联系 group coordinator 并在延迟期间自动获得分配的分区。
如果您使用手动分配，您将获得更少的延迟。