【发布时间】:2017-01-08 06:21:12
【问题描述】:
我已经编写了一个工作服务来使用来自 Kafka 队列的消息,并且我还编写了一个测试脚本来每隔几秒将消息添加到队列中。
我注意到,当消息被添加到队列中时,消费者通常会一次闲置几分钟。然后突然消费者会拿起第一条消息,处理它,然后迅速转移到其余部分。所以它最终会赶上来,但我想知道为什么首先会有这样的延迟?
【问题讨论】:
标签: apache-kafka message-queue messaging kafka-python
我已经编写了一个工作服务来使用来自 Kafka 队列的消息,并且我还编写了一个测试脚本来每隔几秒将消息添加到队列中。
我注意到,当消息被添加到队列中时,消费者通常会一次闲置几分钟。然后突然消费者会拿起第一条消息,处理它,然后迅速转移到其余部分。所以它最终会赶上来,但我想知道为什么首先会有这样的延迟?
【问题讨论】:
标签: apache-kafka message-queue messaging kafka-python
在延迟期间,消费者组将需要一些时间联系组协调员并自动获得分配的分区。
如果你使用手动分配,你会得到更少的延迟。
【讨论】: