问题描述
我有一个带有40个分区的Kafka集群，我发布了几百万条消息。我有大量的消费者，大部分消费者滞后
实验之后，我停止发布任何新消息，而让消费者流失。
但是，我看不到消费者滞后会降到零。对于不同的分区，它介于0-200之间。出于什么原因他们不会为零？
我正在将融合的Kafka python用于生产者和消费者。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）
