Debezium SMT 转换重新路由关键字段设置不起作用
Debezium SMT transform reroute key field setting is not working
我正在尝试使用以下配置。重新路由到一个主题效果很好。但是,配置为关键字段的字段“tableType”未添加到架构中。
我也试过只有“transforms.Reroute.key.enforce.uniqueness=true”来获得默认的 table 名称,但它也不起作用。
transforms="Reroute"
transforms.Reroute.type="io.debezium.transforms.ByLogicalTableRouter"
transforms.Reroute.topic.regex="(.*)\.([A-Z]{3,5}+)\.(.*)$"
transforms.Reroute.topic.replacement=".tables."
transforms.Reroute.key.field.name="tableType"
transforms.Reroute.key.field.regex="(.*)\.([A-Z]{3,5}+)\.(.*)$"
transforms.Reroute.key.field.replacement=""
transforms.Reroute.key.enforce.uniqueness=true
key.converter="io.confluent.connect.avro.AvroConverter"
value.converter="io.confluent.connect.avro.AvroConverter"
...
显然,它正在工作,但它保存在键中而不是值中,这导致了混乱。
我正在尝试使用以下配置。重新路由到一个主题效果很好。但是,配置为关键字段的字段“tableType”未添加到架构中。
我也试过只有“transforms.Reroute.key.enforce.uniqueness=true”来获得默认的 table 名称,但它也不起作用。
transforms="Reroute"
transforms.Reroute.type="io.debezium.transforms.ByLogicalTableRouter"
transforms.Reroute.topic.regex="(.*)\.([A-Z]{3,5}+)\.(.*)$"
transforms.Reroute.topic.replacement=".tables."
transforms.Reroute.key.field.name="tableType"
transforms.Reroute.key.field.regex="(.*)\.([A-Z]{3,5}+)\.(.*)$"
transforms.Reroute.key.field.replacement=""
transforms.Reroute.key.enforce.uniqueness=true
key.converter="io.confluent.connect.avro.AvroConverter"
value.converter="io.confluent.connect.avro.AvroConverter"
...
显然,它正在工作,但它保存在键中而不是值中,这导致了混乱。