开发者社区 > 云原生 > 云消息队列 > 正文

群里大佬 有用golang客户端,遇到过这种报错吗?"新创建的consumerGroup 无法进行

群里大佬 有用golang客户端,遇到过这种报错吗? time="2023-05-31T13:53:28Z" level=error msg="fetch offset of mq from broker error" MessageQueue="MessageQueue [topic=XXXXXXXXXXXXX, brokerName=broker-0, queueId=2]" consumerGroup=XXXXXXXXXXXXXX underlayError="broker response code: 22, remarks: Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first"新创建的consumerGroup 无法进行消费

展开
收起
真的很搞笑 2023-06-06 13:54:14 177 0
2 条回答
写回答
取消 提交回答
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    根据你提供的报错,可以看出是消费者组(Consumer Group)没有在 Broker 中注册成功。该错误信息中的 "broker response code: 22, remarks: Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first" 暗示着消费者组没有正确地同步到 Broker 中。

    这种情况可能有以下几种原因:

    1. 消费者组的配置错误:请检查代码中创建消费者组的相关配置是否正确,例如消费者组名是否与其他消费者组重名等。

    2. 消费者组未正确初始化:在使用消费者组之前,需要先进行初始化操作,确保消费者组能够成功注册到 Broker 中。你可以检查代码中是否完成了消费者组的初始化操作。

    3. Broker 未正常启动或网络异常:如果 Broker 未正常启动或者因为网络等原因无法连接到 Broker,使用消费者组将会失败。你可以检查 Broker 是否正常运行,以及与 Broker 的网络连接是否正常。

    针对这个问题,你可以尝试以下解决办法:

    1. 检查消费者组的配置信息:请仔细检查代码中创建消费者组的相关配置信息,确保配置正确。

    2. 确认消费者组已正确初始化:在使用消费者组之前,需要先进行初始化操作,如调用 Start 方法等,确保消费者组能够成功注册到 Broker 中。

    3. 确认消息主题和队列信息是否正确:请确保代码中消费的消息主题和队列信息与 Broker 中的一致。

    4. 检查 Broker 状态:你可以通过命令行工具查询 Broker 状态,检查 Broker 是否正常运行。

    5. 检查网络连接:如果 Broker 无法连接,可以检查网络连接是否正常。可以使用 telnet 或 ping 命令测试 Broker 的连接状况。

    2023-06-06 16:38:33
    赞同 展开评论 打赏
  • 根据报错信息来看,可能是由于 consumer group 无法找到消费的消息队列引起的。

    出现这种情况的原因可能是:

    1. 消费的消息队列不存在或已被删除。

    2. Consumer Group 配置错误,没有正确订阅消息队列。

    3. Broker 下线或重启导致消费者无法连接到消息队列。

    下面是一些可能的解决方案:

    1. 检查消息队列是否存在,以及消息队列的状态是否正常。

    2. 确认 Consumer Group 配置是否正确。检查您的代码或配置文件,确认是否正确地订阅了对应的消息队列。

    3. 重启 Broker 以重新与 NameServer 同步信息。如果 Broker 无法正常重启,请尝试停止并重启 NameServer。

    如果以上方法无效,请提供更多的上下文信息和代码,以便更详细地判断问题的根本原因。

    2023-06-06 14:22:10
    赞同 展开评论 打赏
问答分类:
Go
问答标签:

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关电子书

更多
阿里开发者手册-Golang专题 立即下载
Golang 微服务在腾讯游戏用户运营领域的探索及实践 立即下载
低代码开发师(初级)实战教程 立即下载