是否可以为每个postgres表定义不同的Reroute.key.field.name



Debezium默认使用主键作为分区键,但是我的一些表应该用不同的键(例如用户(进行分区

因此,我只想对那个特定的表使用:transforms.Reroute.key.field.name=user_id,其余的都将继续使用主键

文档:https://debezium.io/documentation/reference/configuration/topic-routing.html#_example

然而,我不太清楚如何将该转换器仅应用于一个表,而不是所有其他表。

您可以指定message.key.columns连接器选项来自定义组成特定表的消息键的列,而不是重新路由。

message.key.columns=inventory.customers:user_id

相关内容

  • 没有找到相关文章

最新更新