我正在尝试使用下面的配置。转到一个话题上效果很好。但是,字段"tabletype"配置为关键字段时没有添加到模式中。
我也试过只有"transforms. rerroute .key. enforcement .唯一性=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"
...
https://issues.redhat.com/browse/dbz - 3871
显然,它正在工作,但它保存在键中-而不是值中,这导致了混淆。