rocketMQ 遇到消费者报错,求助

[chenfang]

消费者端报错是:

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 应该怎么解决

[fzdwx]

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]

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

[perfectlife]

去找找微信群里提比较快

[chenfang]

@perfectlife 好的我去试试

[lazyfighter]

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