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