-
Enhancement
-
Resolution: Unresolved
-
Minor
-
None
-
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"
}
}
