• 电脑死机重启后服务出现:Failed to start RocketMQ push consumer


    今天电脑无故死机,重启后,微服务启动出现异常:

    2022-11-09 19:04:26 ERROR org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration - Started container failed. DefaultRocketMQListenerContainer{consumerGroup='${rocketmq.consumer.redis-error-group}', namespace='', nameServer='192.168.1.10:9999', topic='xxx', consumeMode=ORDERLY, selectorType=TAG, selectorExpression='*', messageModel=CLUSTERING', tlsEnable=false}
    java.lang.IllegalStateException: Failed to start RocketMQ push consumer
        at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.start(DefaultRocketMQListenerContainer.java:334)
        at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:120)
        at java.util.HashMap.forEach(HashMap.java:1280)
        at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.afterSingletonsInstantiated(ListenerContainerConfiguration.java:79)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:914)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:879)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:551)
        at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141)
        at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747)
        at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:405)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215)
        at cn.zzstc.AdminApplication.main(AdminApplication.java:26)
    Caused by: org.apache.rocketmq.client.exception.MQClientException: the specified group[${rocketmq.consumer.redis-error-group}] contains illegal characters, allowing only ^[%|a-zA-Z0-9_-]+$
    For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
        at org.apache.rocketmq.client.Validators.checkGroup(Validators.java:50)
        at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.checkConfig(DefaultMQPushConsumerImpl.java:661)
        at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.start(DefaultMQPushConsumerImpl.java:581)
        at org.apache.rocketmq.client.consumer.DefaultMQPushConsumer.start(DefaultMQPushConsumer.java:707)
        at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.start(DefaultRocketMQListenerContainer.java:332)
        ... 13 common frames omitted
    [lzm-admin-service]2022-11-09 19:04:26 INFO  org.apache.catalina.core.StandardService - Stopping service [Tomcat]
    [lzm-admin-service]2022-11-09 19:04:26 ERROR org.springframework.boot.SpringApplication - Application run failed
    java.lang.RuntimeException: java.lang.IllegalStateException: Failed to start RocketMQ push consumer
        at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:123)
        at java.util.HashMap.forEach(HashMap.java:1280)
        at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.afterSingletonsInstantiated(ListenerContainerConfiguration.java:79)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:914)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:879)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:551)
        at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141)
        at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747)
        at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:405)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215)
        at cn.zzstc.AdminApplication.main(AdminApplication.java:26)
    Caused by: java.lang.IllegalStateException: Failed to start RocketMQ push consumer
        at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.start(DefaultRocketMQListenerContainer.java:334)
        at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:120)
        ... 12 common frames omitted

    解决方案:

    删掉本地 C 盘下 .rocketmq_offsets 生成的文件。一般路径如下:

    C:\Users\根据实际用户名填写\.rocketmq_offsets

    如图:

    如果还不行,请确保消费者的 consumerGroup 字段能找到对应的分组。因为“消费者必须有对应的Group ID,生产者不做强制要求”。

    更多信息参考官网:Group管理

     

  • 相关阅读:
    (VS报错)已在 xxxxx.exe 中执行断点指令(__debugbreak()语句或类似调用)-解决方法&&C++创建对象四种方式
    多智能体深度强化学习的多无人机协同空战决策
    如何设置CPU节能状态
    女同桌找我要表情包,还好我会Python,分分钟给她下载几十个G...
    小白兔快开门,我是你爸爸。WEB安全基础入门—访问控制漏洞和权限提升
    HDRP shader 获取深度值(方便地)
    YOLOv8-seg改进:SEAM、MultiSEAM分割物与物相互遮挡、分割小目标性能
    文件上传接口
    Java拆装箱
    redis高可用
  • 原文地址:https://blog.csdn.net/BiandanLoveyou/article/details/127775887