springboot 里面异步处理消费到的 kafka 消息,如何保证不丢消息呢

查看 81|回复 3
作者:NoKey   
在 springboot 里面写 kafka 消费代码
为了增加消费速度,写了一个线程池,用来异步处理消费的消息
那么,请教一下各位大佬
如果,异步处理的时候,出现问题了,怎么重复消费这条消息呢?
处理和消费是分开的,处理这里出问题了,消费那里无感知
请各位大佬指点,谢谢

异步, 消费, springboot, Kafka

maocat   
消息 ID ,加日志
totoro52   
消费确认
totoro52   
改为手动确认模式,当消费者消费完成后手动触发确认,MQ 才会删除这条消息。
您需要登录后才可以回帖 登录 | 立即注册

返回顶部