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

SMT - transform reroute add field

    XMLWordPrintable

Details

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

    Description

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

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: