rocketMQ 遇到消费者报错,求助

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

已注册用户请登录

请不要在回答技术问题时复制粘贴 AI 生成的内容

这是一个创建于 1172 天前的主题，其中的信息可能已经有所发展或是发生改变。

消费者端报错是:

2023-01-08 13:17:06,312 WARN RocketmqClient - execute the pull request exception org.apache.rocketmq.client.exception.MQBrokerException: CODE: 24 DESC: the consumer's group info not exist See http://rocketmq.apache.org/docs/faq/ for further details. BROKER: 192.168.1.150:10911 at org.apache.rocketmq.client.impl.MQClientAPIImpl.processPullResponse(MQClientAPIImpl.java:803) at org.apache.rocketmq.client.impl.MQClientAPIImpl.access$200(MQClientAPIImpl.java:175) at org.apache.rocketmq.client.impl.MQClientAPIImpl$2.operationComplete(MQClientAPIImpl.java:754) at org.apache.rocketmq.remoting.netty.ResponseFuture.executeInvokeCallback(ResponseFuture.java:54) at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$2.run(NettyRemotingAbstract.java:321) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) 2023-01-08 13:17:06,374 WARN RocketmqClient - execute the pull request exception org.apache.rocketmq.client.exception.MQBrokerException: CODE: 24 DESC: the consumer's group info not exist See http://rocketmq.apache.org/docs/faq/ for further details. BROKER: 192.168.1.150:10911 at org.apache.rocketmq.client.impl.MQClientAPIImpl.processPullResponse(MQClientAPIImpl.java:803) at org.apache.rocketmq.client.impl.MQClientAPIImpl.access$200(MQClientAPIImpl.java:175) at org.apache.rocketmq.client.impl.MQClientAPIImpl$2.operationComplete(MQClientAPIImpl.java:754) at org.apache.rocketmq.remoting.netty.ResponseFuture.executeInvokeCallback(ResponseFuture.java:54) at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$2.run(NettyRemotingAbstract.java:321) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833)

broker 的日志是:

 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_76 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_28 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:03 WARN PullMessageThread_76 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group 2023-01-08 13:18:04 WARN PullMessageThread_84 - the consumer's group info not exist, group: real_db_one_consumer_group

rocketMQ 版本是 4.9.4,本来消费好好的,今天突然有延迟,然后去 dashboard 上看,发现这个消费者组有 tps 很低 ,但是数量为 0,于是我就去看消费者端的 mq 日志以及 broker 的日志,分别发现了这两个问题,这个我大概看了一下 rockeyMQ 的源码,跟 netty 有关,这就有点难搞了

有人遇到过么,或者这个 bug 应该怎么解决

5 条回复 2023-01-09 14:59:32 +08:00

lllllliiii

2023 年 1 月 8 日

rocketmq 没有发 issue 的地方吗？

`CODE: 24 DESC: the consumer's group info not exist`
`the consumer's group info not exist, group: real_db_one_consumer_group`

可以从这两句日志入手啊。

chenfang

2023 年 1 月 8 日 via iPhone

@fzdwx 有但是貌似没人管，之后看了看貌似跟 netty 有关系，之后就整不会了

perfectlife

2023 年 1 月 8 日

去找找微信群里提比较快

chenfang

2023 年 1 月 8 日

@perfectlife 好的我去试试

lazyfighter

2023 年 1 月 9 日

目测就是没有创建消费者组，rocketmq 需要自己创建消费者组