Hi, 请检查一下服务端和客户端版本。另外,如果是问题支持,请大家发到user邮件列表。具体邮件列表功能,请参考官网说明[1].
[1] http://rocketmq.apache.org/about/contact/ <http://rocketmq.apache.org/about/contact/> Best Regards, Von Gosling > 在 2018年4月23日,19:27,张弢 <zhang...@pingpongx.com> 写道: > > 尊敬的rocketMQ开发者: > 我是一名使用rocketMQ的开发者,我使用的版本是4.2.0 在使用过程中遇到一个问题: > [2018-04-23 15:30:15,729] WARN [NettyClientPublicExecutor_2] > RocketmqClient:384 execute the pull request exception > org.apache.rocketmq.client.exception.MQBrokerException: CODE: 25 DESC: the > consumer's subscription not latest > For more information, please visit the url, > http://rocketmq.apache.org/docs/faq/ > at > org.apache.rocketmq.client.impl.MQClientAPIImpl.processPullResponse(MQClientAPIImpl.java:640) > at > org.apache.rocketmq.client.impl.MQClientAPIImpl.access$200(MQClientAPIImpl.java:155) > at > org.apache.rocketmq.client.impl.MQClientAPIImpl$2.operationComplete(MQClientAPIImpl.java:592) > at > org.apache.rocketmq.remoting.netty.ResponseFuture.executeInvokeCallback(ResponseFuture.java:51) > at > org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$2.run(NettyRemotingAbstract.java:286) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) > at java.util.concurrent.FutureTask.run(FutureTask.java:262) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:745) > > 我搜索了很多,但是没有合适的解决方案。更多的是说订阅版本不一致。 > // 校验 订阅信息版本 是否合法 if (subscriptionData.getSubVersion() < > requestHeader.getSubVersion()) { LOG.warn("The broker's subscription is not > latest, group: {} {}", requestHeader.getConsumerGroup(), > subscriptionData.getSubString()); > response.setCode(ResponseCode.SUBSCRIPTION_NOT_LATEST); > response.setRemark("the consumer's subscription not latest"); return > response; } > > 希望能得到你们的回复。 > > Thanks >