这家伙太懒,什么都没留下
我也是遇到同样的问题
已经解决了,中间有一个重新分配分区的日志,之前一直没看到。原因就是一次获取500条消息的处理时间大于了max.poll.interval.ms这个值
从日志看没有报错信息,如果有异常,应该会打印的
我重新安装了一遍kafka,已经好使了,我在努力重现这个问题,也不出现了
kafka_2.10-0.10.1.0 kafka版本,单机模式