Debezium默认使用主键作为分区键,但是我的一些表应该使用不同的键(例如user)
因此,我只想对该特定表使用:transforms.Reroute.key.field.name=user_id,其余所有表都将继续使用主键
文档:https://debezium.io/documentation/reference/configuration/topic-routing.html#_example
但是,我不太清楚如何将该转换器仅应用于一个表,而不是所有其他表。
发布于 2021-04-16 14:28:35
您可以指定message.key.columns连接器选项来自定义构成特定表的消息键的列,而不是重新路由。
message.key.columns=inventory.customers:user_idhttps://stackoverflow.com/questions/67083296
复制相似问题