nancy网站开发,系统开发立项报告,深圳地铁建设有限公司,新中国风装修场景 想创建一个新的consumer去消费一个已经再使用的topic时#xff0c;默认情况下会从topic中的第一条消息开始消费#xff0c;大多数情况是需要从最新的消息开始。然后再使用CONSUME_FROM_LAST_OFFSET设置时并不会对新的consumer生效#xff0c;它只是在停用consumer重新启…场景 想创建一个新的consumer去消费一个已经再使用的topic时默认情况下会从topic中的第一条消息开始消费大多数情况是需要从最新的消息开始。然后再使用CONSUME_FROM_LAST_OFFSET设置时并不会对新的consumer生效它只是在停用consumer重新启用时如果之前订阅OFFSET消息已经不存在了默认rocketmq中存放的消息是72小时就会从最后一条开始。所以代码层面无法实现新的consumer订阅topic最新消息开始消费的操作。
如何实现 RocketMQ为我们提供了一个强大的消息控制台rocketmq-dashboard,其中就有消息相关的控制功能。操作步骤如下 1.创建新的consumer已存在可以跳过这一步
Consumeradd clusterName:选择需要订阅rocketmq集群名称brokerName选择需要订阅的broker名称可能是多组集群groupName输入新建的Consumer名称consumeEnable是否开启Consumer消费这里先将消费关闭灰色启动后再开启消费。 2.启动消费组程序,已启动的跳过。 启动消费程序后就可以看到Consumer消费节点数量延时的消息数量。因为我们consumeEnable为false关闭状态所有Consumer并没有消费消息。 3.设置Consumer消费offset
TopicSKIP_MESSAGE_ACCUMULATE 在Topic栏目中选择需要跳过的topic点击SKIP_MESSAGE_ACCUMULATE操作在SKIP_MESSAGE_ACCUMULATE弹出框SubscriptionGroup中选择需要操作的消费组commit后生效弹出设置的消费信息框如下 如果新的Consumer订阅了多个topic也需要将其他进行操作。
4.开启consumeEnable开关
ConsumerConfig 在Consumer的模块中找到新增的消费组SubscriptionGroup 打开后面Config窗口 打开consumeEnable开关红色如果有过个broker集群需要都打开。设置完成后消费程序会开始消费新的消息
