Re: 关于CODE:25的问题

[Von Gosling <vo...@apache.org>]

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，张弢 <zh...@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
>