卡夫卡消费者滞后不为零

如何解决卡夫卡消费者滞后不为零

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

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

但是，我看不到消费者滞后会降到零。对于不同的分区，它介于0-200之间。出于什么原因他们不会为零？

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