kafka生产者缓冲池内还未发送的消息宕机丢失怎么办?

之前被问到了这个问题,答可以发送前把消息落库保存,面试官似乎不太满意

全部评论
ack设置为等kafka的broker/brokers确认收到消息后才认为发送成功的那两个参数,send方法传入回调函数,发送成功就将消息状态设置为成功,否则就是默认不成功的状态(上游生产者至少得持久化保存消息吧)。宕机恢复后,通过那个啥注解,在spring启动时执行预定方法,扫描不成功的消息,再次发送
点赞 回复 分享
发布于 05-23 23:45 新疆
点赞 回复 分享
发布于 2024-10-21 22:55 江苏
消费者消费完消息手动ack,如果生产者没有收到消费者的ack默认消息丢失重发消息
点赞 回复 分享
发布于 2024-10-20 11:07 美国
点赞 回复 分享
发布于 2024-10-18 20:24 浙江

相关推荐

评论
点赞
5
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务