V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
chenfang
V2EX  ›  程序员

rocketMQ 遇到消费者报错,求助

  •  
  •   chenfang · 2023-01-08 17:25:39 +08:00 · 1547 次点击
    这是一个创建于 445 天前的主题,其中的信息可能已经有所发展或是发生改变。

    消费者端报错是:

    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
        1
    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
        2
    chenfang  
    OP
       2023-01-08 18:10:54 +08:00 via iPhone
    @fzdwx 有 但是貌似没人管 ,之后看了看貌似跟 netty 有关系, 之后就整不会了
    perfectlife
        3
    perfectlife  
       2023-01-08 19:33:00 +08:00
    去找找微信群里提比较快
    chenfang
        4
    chenfang  
    OP
       2023-01-08 20:39:00 +08:00
    @perfectlife 好的我去试试
    lazyfighter
        5
    lazyfighter  
       2023-01-09 14:59:32 +08:00
    目测就是没有创建消费者组,rocketmq 需要自己创建消费者组
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   2302 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 27ms · UTC 16:12 · PVG 00:12 · LAX 09:12 · JFK 12:12
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.