这家伙太懒,什么都没留下
嗯 非常感谢你的建议,丢消息这个情况是出现在线上,线上不好进行同步测试,我们都是异步在发送
客户端程序丢失消息的情况有很多,比如测试程序结束了,但是消息还在缓冲区还没来得急发送,进程就结束了。
你可以用同步进行测试,在发送后面加.get()
.get()
嗯 程序这边看日志是没有发现任务异常的,其他的消息也对比找过能够在kafka的消息日志里面找到
确认过消息是丢了吗?
会不会是那个缓冲区,由于发消息太快,缓冲满了后把后加入的消息丢掉了?