kafka消费数据时刚开始消费正常,消费一段时间之后就停止消费了。消费者端也不报错。 我是用的是Consumer.assign(),指定topic和分区,进行手动offset提交,并进行redis存储offset。 kafka版本kafka_2.11-2.2.0
应该是你的程序写的不健壮导致的,检查下程序。
例如:消费者的这个线程被释放了
你的答案