我正在尝试使用下面的配置。重新路由到一个主题效果很好。但是,配置为关键字段的"tableType“字段不会添加到模式中。
我还尝试只使用"transforms.Reroute.key.enforce.uniqueness=true“来获取默认的表名称,但也不起作用。
transforms="Reroute"
transforms.Reroute.type="io.debezium.transforms.ByLogicalTableRouter"
transforms.Reroute.topic.regex="(.*)\\.([A-Z]{3,5}+)\\.(.*)$"
transforms.Reroute.topic.replacement="$1.tables.$3"
transforms.Reroute.key.field.name="tableType"
transforms.Reroute.key.field.regex="(.*)\\.([A-Z]{3,5}+)\\.(.*)$"
transforms.Reroute.key.field.replacement="$2"
transforms.Reroute.key.enforce.uniqueness=true
key.converter="io.confluent.connect.avro.AvroConverter"
value.converter="io.confluent.connect.avro.AvroConverter"
...发布于 2021-08-17 12:27:38
显然,它是有效的,但它保存在键中,而不是值中,这导致了混乱。
https://stackoverflow.com/questions/68778495
复制相似问题