-
Notifications
You must be signed in to change notification settings - Fork 938
Description
在spring boot 2.4.x版本下,使用remoting依赖rocketmq-spring-boot-starter无论任何版本,在启动时可以拉取到消息,但是启动后,就无法继续拉取消息,报错如下:
2026-01-20 10:13:31.313 WARN [131680] [NettyClientPublicExecutor_9] [o.a.r.c.i.c.DefaultMQPushConsumerImpl#?:?] - execute the pull request exception, group=GID_NORMAL_DEV, messageQueue=MessageQueue [topic=normal_dev, brokerName=a97eeb9b0a4-broker-1, queueId=0]
org.apache.rocketmq.client.exception.MQBrokerException: CODE: 24 DESC: the consumer's subscription not exist BROKER: 127.0.0.1:8080
For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processPullResponse(MQClientAPIImpl.java:1152)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.access$200(MQClientAPIImpl.java:257)
at org.apache.rocketmq.client.impl.MQClientAPIImpl$5.operationSucceed(MQClientAPIImpl.java:1109)
at org.apache.rocketmq.remoting.netty.NettyRemotingClient$InvokeCallbackWrapper.operationSucceed(NettyRemotingClient.java:1117)
at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$invokeAsyncImpl$5(NettyRemotingAbstract.java:604)
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646)
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$1.operationSucceed(NettyRemotingAbstract.java:548)
at org.apache.rocketmq.remoting.netty.ResponseFuture.executeInvokeCallback(ResponseFuture.java:67)
at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$executeInvokeCallback$2(NettyRemotingAbstract.java:412)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
订阅关系在控制台查询可以看到已经创建,升级spring boot到starter对应的2.7.15后,问题解决