Apache RocketMQ5,同一个消费者,返回了ConsumeResult.SUCCESS之后,又再一次被消费到了..谁碰到过这种情况吗?broker有重启过
Apache RocketMQ5,同一个消费者[阿里云消息队列MQ]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
同尘云，您身边的云智能顾问
Apache RocketMQ5,同一个消费者,返回了ConsumeResult.SUCCESS之后,又再一次被消费到了..谁碰到过这种情况吗?broker有重启过
在 Apache RocketMQ 中，如果一个消费者返回 ConsumeResult.SUCCESS，表示消息已经被成功消费，并且不会再次消费。如果同一个消费者又再一次收到了相同的消息，可能有以下几个原因：
消息重复发送：消息可能被重复发送到了 RocketMQ 中，导致同一个消息被消费多次。可以通过查看消息的唯一标识符（Message ID）来判断是否为同一个消息。
消费者异常退出：如果消费者异常退出，RocketMQ 会自动将该消费者的消费进度保存在服务器端，如果消费者重新启动，会从上次消费的位置继续消费。如果消费者进度保存失败，可能会导致消息被重复消费。
消息重复存储：如果消息存储失败，可能会导致同一条消息被多次存储到 RocketMQ 中，从而被多次消费。
针对上述情况，可以采取以下措施：
在生产者端，使用消息的唯一标识符（Message ID）来保证消息不被重复发送。
在消费者端，保证消费者进度的正确性和可靠性，可以使用 Checkpoint 功能来定期保存消费进度。
在 RocketMQ 中，已经提供了幂等消费的解决方案，可以通过在消费端实现幂等性来避免重复消费。
【回答】
可以参照以下这三种方案：
避免消息重复产生，找到原因，并做代码的限制。
消费数据时利用Java代码做ID的重复校验，重复则放弃，并返回异常信息。也可以考虑针对数据库有条件的插入语句，限制重复插入。
消费数据时，通过订阅的记录和消费的结果来判断，此消息是否重复订阅过，如果重复订阅，则不在数据库中插入数据。
在消费offset没有持久化之前重启，可能发生的 ，做好幂等一般没啥问题的，此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”