本文主要是介绍RocketMQ:新增consumer消费组group从最新消息开始消费skip last offset message，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
场景
想创建一个新的consumer去消费一个已经再使用的topic时，默认情况下会从topic中的第一条消息开始消费，大多数情况是需要从最新的消息开始。然后再使用CONSUME_FROM_LAST_OFFSET设置时并不会对新的consumer生效，它只是在停用consumer重新启用时，如果之前订阅OFFSET消息已经不存在了（默认rocketmq中存放的消息是72小时）就会从最后一条开始。所以代码层面无法实现新的consumer订阅topic最新消息开始消费的操作。
如何实现
RocketMQ为我们提供了一个强大的消息控制台rocketmq-dashboard,其中就有消息相关的控制功能。操作步骤如下：
1.创建新的consumer，已存在可以跳过这一步
Consumer>add
- clusterName:选择需要订阅rocketmq集群名称
- brokerName：选择需要订阅的broker名称，可能是多组集群
- groupName：输入新建的Consumer名称
- consumeEnable：是否开启Consumer消费，这里先将消费关闭（灰色），启动后再开启消费。
2.启动消费组程序,已启动的跳过。
- 启动消费程序后就可以看到Consumer消费节点数量，延时的消息数量。
- 因为我们consumeEnable为false关闭状态，所有Consumer并没有消费消息。
3.设置Consumer消费offset
- Topic>SKIP_MESSAGE_ACCUMULATE
- 在Topic栏目中选择需要跳过的topic，点击SKIP_MESSAGE_ACCUMULATE操作
- 在SKIP_MESSAGE_ACCUMULATE弹出框SubscriptionGroup中选择需要操作的消费组
- commit后生效，弹出设置的消费信息框如下
- 如果新的Consumer订阅了多个topic，也需要将其他进行操作。
4.开启consumeEnable开关
Consumer>Config
- 在Consumer的模块中，找到新增的消费组SubscriptionGroup ，打开后面Config窗口
- 打开consumeEnable开关（红色），如果有过个broker集群需要都打开。
- 设置完成后消费程序会开始消费新的消息
这篇关于RocketMQ:新增consumer消费组group从最新消息开始消费skip last offset message的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
