alter ddl语句写入kafka的topic 分区规则是啥样的
你好，我现在遇到一个问题，我们是canal --> kafka ，一个topic 三个partition ,通过hash将dml语句写入某个partition,现在问题是，对ddl语句，里面是没有数据字段使用hash 落到某个partition的，请问对于ddl语句是按照什么规则写入哪个partition的 ？
原提问者GitHub用户Bruce2jiang
展开
收起
1
条回答
写回答
写回答
-
if (rowChange.getIsDdl()) { partitionEntries[0].add(entry); } 具体看类 MQMessageUtils的messagePartition 206行 DDL语句统一写到0分区
原回答者GitHub用户yangyiweigege
2023-05-05 10:09:24赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
