rocketMQ 遇到消费者报错,求助

2023-01-08 17:25:39 +08:00
 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 应该怎么解决

1765 次点击
所在节点    程序员
5 条回复
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
@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 需要自己创建消费者组

这是一个专为移动设备优化的页面（即为了让你能够在 Google 搜索结果里秒开这个页面），如果你希望参与 V2EX 社区的讨论，你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/907385

V2EX 是创意工作者们的社区，是一个分享自己正在做的有趣事物、交流想法，可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX