开发者社区 问答 正文

ddl默认投递到partition 0(队列0)的问题

canal对接RocketMQ,启用 partitionHash时,ddl语句都固定投递到队列0,与数据是同一个队列 请问这样做是基于什么考虑呢?

MQMessageUtils.messagePartition方法中 if (flatMessage.getIsDdl()) { partitionMessages[0] = flatMessage; }

另外这中情况下,ddl 和 dml不在同一个队列中,对client 顺序消息处理有什么影响?

原提问者GitHub用户flackyang

展开
收起
Java工程师 2023-05-03 10:55:16 79 分享 版权
1 条回答
写回答
取消 提交回答
  • query语句除了ddl以外还有部分dml query,没法获取完整的dbname和tbname,所以统一按照分区0进行发送

    原回答者GitHub用户agapple

    2023-05-04 14:57:40
    赞同 展开评论
问答分类:
问答地址: