【问题标题】:Why is there a delay between writing to and reading from Kafka queue?为什么写入和读取 Kafka 队列之间存在延迟?
【发布时间】:2017-01-08 06:21:12
【问题描述】:

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

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

【问题讨论】:

    标签: apache-kafka message-queue messaging kafka-python


    【解决方案1】:

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

    如果你使用手动分配,你会得到更少的延迟。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2020-10-01
      • 2021-01-20
      • 2019-07-26
      • 2015-10-06
      • 2018-06-04
      • 2020-01-21
      • 2021-04-12
      相关资源
      最近更新 更多