尊敬的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

Reply via email to