返回到文章

采纳

编辑于

kafka java客户端消费不到消息,但也不报错

kafka

发现最近很多人遇到kafka客户端消费时,拿不到消息的情况,我来推荐几个排查的方式。

  1. 通过集群的命令启动消费者,同步监控,确保消息确实有。
    (如果是自己写的客户端发送,建议使用官方提供java例子,自己写的发送我不知道你是怎么实现的,很多自己改了客户端,发送时由于消息还在缓存中,还没来的及发送,程序就已经结束了,导致的消息丢失了)

  2. 先启动客户端的消费者,再发送消息
    (只有第一次需要,因为在此之前,还没有注册到消费列表中,之前在topic里的消息就不会被刚启动的消费者消费到。)