怎么解决了吗
你好,我也发现这个问题,开启一个新的消费组,第一次启动的时候不生效,请问你解决了没有?
是的,我期望是,当我用一个新的组去消费的时候,从当前时间开始消费,10天前的消息不消费
回复你新的组的group以及topic和现在一样吗?
consumer.setConsumeTimestamp(UtilAll.timeMillisToHumanString3( System.currentTimeMillis() - (1000 * 60 * 1)));
你设置的是从一分钟前开始消费啊。。。
这是你业务逻辑做的吧,本来mq就是这样消费的。
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
暂无简介
文章 0 评论 0
接受
发布评论
评论(6)
怎么解决了吗
你好,我也发现这个问题,开启一个新的消费组,第一次启动的时候不生效,请问你解决了没有?
是的,我期望是,当我用一个新的组去消费的时候,从当前时间开始消费,10天前的消息不消费
回复
你新的组的group以及topic和现在一样吗?
你设置的是从一分钟前开始消费啊。。。
这是你业务逻辑做的吧,本来mq就是这样消费的。