这家伙太懒,什么都没留下
我在用cppkafka库的时候,遇到了同样的问题,解决办法是转了string。
没发现其他异常
你生产者send的时候要自己去捕获异常(send方法的第二个参数可以指定。如果直接使用try catch是无法知道是否生产者有问题。)。另外建议提高生产者重试次数。我有遇到这种情况。生产者显示丢一条记录。同样也是在broker Controller 切换的时候
我目前还没遇到丢消息的情况。建议你改为同步发送。先排除掉生产丢消息的情况。
是的,kafka的ack是业务级的,理论上上kafka没接收到生产者应该是发送失败的,这样消息丢失是说得通的,但是我的生产者问题发生时没有错误上报,这个一直想不明白。