kafka多分区消费问题

傲月 发表于: 2018-01-22   最后更新时间: 2018-01-22  
  •   21 订阅,203 游览

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

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

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







发表于: 1月前   最后更新时间: 1月前   游览量:203
上一条: Kafka使用kerberos连接zookeeper时无法连接,帮忙看看,感谢!
下一条: kafka connector运行的在哪

评论…


  • 先查询下集群的状态:kafka命令大全:http://orchome.com/454
    是否是始终没人消费,还是过一段时间就会消费?
  • 评论…
    • in this conversation
      提问