【RabbitMQ】如何保证消息消费时的幂等性+如何处理消息丢失的问题

一、如何保证消息消费时的幂等性       这个问题可以等价于如何保证消费不被重复消费?为什么在消费队列里消费到了重复的数据。 1、kafak消费端可能导致的重复消费问题                              消费者准备提交offset,但还没有提交的时候,消费者进程被重启了。那么此时已经消费过的数据offset还没有提交。kafka也就不知道你消费了offset=153的那条
相关文章
相关标签/搜索