GitHub user MrZbb added a comment to the discussion: 请教个广播模式下如何避免重复消费的问题
Thanks. Currently, I am using the PostConstruct method to query the local offsets file of the machine instance during application startup and delete it directly. This does ensure that each time the broadcast mode is used, the problem of old data being re-consumed after a machine is unavailable for a period of time and restarted is resolved. However, I feel that this approach is a bit of a workaround GitHub link: https://github.com/apache/rocketmq/discussions/6619#discussioncomment-5657688 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
