本例主要演示springboot和kafka集成,实现消费端幂等消费
实现原理如下:
- 1、生产者发送消息时,携带一个全局唯一的id
- 2、消费端消费时,先根据这个全局唯一的id去redis查询一下
- 3、如果该ID已经被消费过,则不进行处理
- 4、如果该ID没被消费过,则进行处理,处理结束后,把该ID存入redis,且value设置为已消费
注:消费端必须开启手动确认,不能是自动确认
Name | Name | Last commit date | ||
---|---|---|---|---|
parent directory.. | ||||
本例主要演示springboot和kafka集成,实现消费端幂等消费
实现原理如下:
注:消费端必须开启手动确认,不能是自动确认