这家伙太懒,什么都没留下
现在什么情况了?
有个思路,可以考虑消费者offset重写到kafka或者zookeeper里。参考:迁移offset从zookeeper到kafka
kafka是0.11.0版本的 kafka_2.11-0.11.0.0.jar,一月份出的故障kafka启动后没有什么异常,应用能正常消费,我检查下日志情况。
给点时间,让它们赶上(如果持续赶不上,需要查看性能是否已经达到瓶颈了)。