ticdc能不能根据指定列名来分发到kafka partition?

目前只有rowid,ts,table模式来分发

能不能根据指定的列名来做分发?

1 个赞


1)只有这四种,目前不可以(指定列是int类型主键, 还可以再讨论)
2)如果想实现,有点复杂
(1)sink可以接pulsar,然后再根据消息类型,写一个function再次路由到另外一个topic
(2)或者接rabbitmq,根据消息类型再次路由下。

1 个赞

好的,多谢回复

此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。