文章目录 概览消息发送异常时重复发送消费消息抛出异常消费者提交offset失败服务端持久化offset失败主从同步offset失败重平衡清理长时间消费的消息总结 概览 消息发送异常时重复发送 首先,我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。 如图,简单说一下上图中的概念: Broker,就是RocketMQ的服务端,如上图就有两个服务实例Topic就是一类消息集合的名字Queue就是Topic的对应的队列,消息都存在Queue上,每个Topic都会有自己的几个Queue 所以,整个消息发送和消费过程大致如下: 生产者在发送消息之前根据负载均衡