kafka多分区消费问题

kafka多线程消费多分区数据时,刚开始每个线程消费各分区的数据都是正常的,但运行了一段时间后,其中一个分区的数据就没有被消费了,用命令查看lag,在持续增长. 另外kafka的日志和订阅代码的日志,都没有任何异常.

消费的代码和您教程中的示例是一样的.

麻烦问下,有没有遇到过这种情况,或有没有解决的思路...