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