我有一个kafka集群，有40个分区，发布了几百万条消息。我有一个消费者池，大部分消费者滞后<100。
在我的实验之后，我停止发布任何新的信息，并让消费者流失。
但是，我没有看到消费者滞后降到零。对于不同的分区，它在0-200之间。有什么理由不归零吗？
我正在为生产者和消费者使用合流的kafka python。