TiDB 的问答社区
ticdc能不能根据指定列名来分发到kafka partition?
🪐 TiDB 技术问题
备份&数据迁移
TiCDC
,
TiDB-v5
lindoubled
(Lindoubled)
2022 年2 月 28 日 08:38
1
目前只有rowid,ts,table模式来分发
能不能根据指定的列名来做分发?
1 个赞
Meditator
(Wendywong020)
2022 年2 月 28 日 09:47
2
image
734×154 7.64 KB
1)只有这四种,目前不可以(指定列是int类型主键, 还可以再讨论)
2)如果想实现,有点复杂
(1)sink可以接pulsar,然后再根据消息类型,写一个function再次路由到另外一个topic
(2)或者接rabbitmq,根据消息类型再次路由下。
1 个赞
lindoubled
(Lindoubled)
2022 年2 月 28 日 10:48
3
好的,多谢回复
system
(system) 关闭
2022 年10 月 31 日 19:09
4
此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。
©2023 TiDB Community.
京ICP备20022552号-5
京公网安备11010802043344号