开发者社区> 问答> 正文

MQ为阿里云Rocket MQ的时候partitionsNum 和 partitionHash无效的

去年开始issues里面就有很多人提出这个问题,但是依然无任何回复解决。

阿里云的RocketMq服务 topic下的同一个group有4台机器消费集群

instance.propertios配置如下参数

#canal.mq.partition=1 canal.mq.partitionsNum=4 canal.mq.partitionHash=...:id 但是收到的消息依然是其中一台,剩余3台没有过消息接收 如何配置才能够分散到多台机器消费呢

原提问者GitHub用户farsunset

展开
收起
山海行 2023-04-27 20:10:31 155 0
1 条回答
写回答
取消 提交回答
  • 最新代码已经修复

    原回答者GitHub用户agapple

    2023-04-28 14:40:23
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载