rocketMQ 遇到消费者报错,求助

V2EX = way to explore

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

现在注册

已注册用户请登录

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

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

消费者端报错是:

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

fzdwx

2023-01-08 17:47:23 +08:00

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-01-08 18:10:54 +08:00 via iPhone

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

perfectlife

2023-01-08 19:33:00 +08:00

去找找微信群里提比较快

chenfang

2023-01-08 20:39:00 +08:00

@perfectlife 好的我去试试

lazyfighter

2023-01-09 14:59:32 +08:00

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