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

Providing an unwrap SMT example together with DBZ JDBC Sink

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Obsolete
    • Icon: Minor Minor
    • None
    • None
    • examples
    • None
    • False
    • None
    • False

      Feature request or enhancement

      Which use case/requirement will be addressed by the proposed feature?

      Hi, Team,

      I find that there is an unwrap-smt example in the github directory based on the Confluent JDBC Sink Connector.

      Now there is a generic DBZ JDBC Sink Connector, I think it would be great to provide a similar example based on JDBC Sink Connector, too.

       

      Best Regards.

      Implementation ideas (optional)

      I try to modify the existing example as below.

      {
          "name": "jdbc-sink",
          "config": {
              "connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector",
              "tasks.max": "1",
              "topics": "customers",
              "table.name.format": "${topic}",
              "connection.url": "jdbc:postgresql://postgres:5432/inventory",
              "connection.username": "postgresuser",
              "connection.password": "postgrespw",
              "transforms": "unwrap",
              "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
              "transforms.unwrap.drop.tombstones": "false",
              "schema.evolution": "basic",
              "insert.mode": "upsert",
              "delete.enabled": "true",
              "primary.key.fields": "id",
              "primary.key.mode": "record_key"
          }
      }
      

            Unassigned Unassigned
            chaiachun Chia-Chun Hsu (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: