RocketMQ 如何保证消息不丢失
首先在如下三个部分都可能会出现丢失消息的情况：
Producer 端
Broker 端
Consumer 端
Producer 端如何保证消息不丢失
采取 send()同步发消息，发送结果是同步感知的。
发送失败后可以重试，设置重试次数。默认 3 次。
producer.setRetryTimesWhenSendFailed(10);
集群部署，比如发送失败了的原因可能是当前 Broker 宕机了，重试的时候会发送
到其他 Broker 上。
Broker 端如何保证消息不丢失
修改刷盘策略为同步刷盘。默认情况下是异步刷盘的。
flushDiskType = SYNC_FLUSH
集群部署，主从模式，高可用。
Consumer 端如何保证消息不丢失
完全消费正常后在进行手动 ack 确认。
RocketMQ 的消息堆积如何处理
1. 如果可以添加消费者解决，就添加消费者的数据量.
2、如果出现了 queue，但是消费者多的情况。可以使用准备一个临时的 topic，同时创建
一些 queue，在临时创建一个消费者来把这些消息转移到 topic 中，让消费者消费。
