开发者社区> 问答> 正文

RocketMQ配置分区,集群模式下多消费实例,只有一个消费实例可以收到消息

版本

1.1.6

分区配置

canal.mq.dynamicTopic=trade:dy.\.trades,trade_his:dy.\.trades_his_xdaysago canal.mq.partitionsNum=32 canal.mq.partitionHash=.\..:tid

tid是表的主键。

问题

阿里RocketMQ,集群模式下多消费实例,只有一个消费实例可以收到消息。 本以为是阿里RocketMQ的问题,提工单让他们技术查的结果是,未收到消息的消费实例分配的队列根本没有接收到消息。

帮忙看看还需要怎么去配置?

原提问者GitHub用户zhangpf1127

展开
收起
白夜行fighting 2023-04-25 20:42:03 308 0
1 条回答
写回答
取消 提交回答
  • 重新梳理了一下wiki上的设置,尝试通过设置canal.mq.enableDynamicQueuePartition来动态获取MQ服务端的分区数,使用阿里RocketMQ的小伙伴,如果有集群模式下只有一个消费实例能够收到消息的问题,可以尝试配置canal.mq.enableDynamicQueuePartition=true 试试。

    原回答者GitHub用户zhangpf1127

    2023-04-26 17:26:16
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
行业实践:RocketMQ 业务集成典型行业应用和实践 立即下载
技术揭秘:RocketMQ 5.0 云原生架构升级之路 立即下载
RocketMQ Summit 2022 开源生态发展 立即下载