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

lindoubled · 2022 年2 月 28 日 08:38

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

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

Meditator · 2022 年2 月 28 日 09:47

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

lindoubled · 2022 年2 月 28 日 10:48

好的，多谢回复

system · 2022 年10 月 31 日 19:09

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