Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-3871

SMT - transform reroute add field

XMLWordPrintable

    • Icon: Feature Request Feature Request
    • Resolution: Not a Bug
    • Icon: Major Major
    • None
    • 1.7.0.Alpha1
    • None
    • False
    • False
    • undefined

      I am trying to use the configurations below. Rerouting to a topic works well. However, the field "tableType" configured as a key field is not added to the schema.

      I also tried to have only "transforms.Reroute.key.enforce.uniqueness=true" to get the default table name but it doesn't work either.

      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"
      ...

              Unassigned Unassigned
              guyromb2 Guy Rombaut (Inactive)
              Votes:
              1 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: