python-2.7 - 卡夫卡消费者滞后不是零

Question

我有一个有 40 个分区的 Kafka 集群，我发布了几百万条消息。我有一个消费者群体，大部分消费者滞后<100。

在我的实验之后，我停止发布任何新消息并让消费者流失。

但是，我认为消费者滞后不会降到零。对于不同的分区，它在 0-200 之间敲击。有什么理由他们不会是零？

我正在为生产者和消费者使用融合的 Kafka python。

标签： python-2.7apache-kafkaconfluent-kafka-python