这家伙太懒,什么都没留下
查看topic那些负数的分区是否是正常的。
bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic foo --describe
如果都正常,lag负数的分区offset也一直在增长,可查看lag为负数的原因:kafka consumer lag 为负数