使Kafka消费者在python中存活的最佳做法是什么？

Question

在使消费者保持生命力方面，有些事情令我感到困惑。假设我有一个不断向其写入数据的主题。但是，在一天的一个小时内，没有新消息。如果我为我的使用者设置了超时，那么当没有新消息时，使用者将被关闭。

现在，新邮件到达。但是，没有活着的消费者去消费它们。

我应该如何处理这种情况？我的消费者可能会消费所有消息并被关闭。使它们存活的最佳方法是什么？有什么方法可以在收到新消息时自动调用它们？这种情况下的最佳做法是什么？

Answer 1

为什么不只是

import time


while True:
    # Consume your messages
    # ...

    # if the timeout has been reached, sleep for e.g. 60 seconds
    time.sleep(60)