Debezium config example for Src and Src COnnector

{

“name”: “MSSQLConn”,

“config”: {

“connector.class” : “io.debezium.connector.sqlserver.SqlServerConnector”,

“tasks.max” : “1”,

“database.server.name” : “TestDB1”,

“database.hostname” : “10.58.181.105”,

“database.port” : “1433”,

“database.user” : “testUser”,

“database.password” : “P#”,

“database.dbname” : “testDB1”,

“database.history.kafka.bootstrap.servers” : “localhost:9092”,

“database.history.kafka.topic”: “schema-changes.inventory”

}

}


{

“name”: “MSSQLConn”,

“config”: {

“connector.class” : “io.debezium.connector.sqlserver.SqlServerConnector”,

“tasks.max” : “1”,

“database.server.name” : “TestDB1”,

“database.hostname” : “10.58.181.105”,

“database.port” : “1433”,

“database.user” : “testUser”,

“database.password” : “P#”,

“database.dbname” : “testDB1”,

“database.history.kafka.bootstrap.servers” : “localhost:9092”,

“database.history.kafka.topic”: “schema-changes.inventory”

}

}

–sink

{

“name”:”SinkX”,

“config”:{

“connector.class”:”io.confluent.connect.jdbc.JdbcSinkConnector”,

“tasks.max”:”1″,

“topics”:”TestDB1.dbo.customers”,

“connection.url”:”jdbc:sqlserver://10.58.181.105:1433;database=testdb;username=testUser;password=P1″,

“insert.mode”:”upsert”,

“table.name.format”:”customers”,

“pk.mode”:”record_value”,

“pk_fields”:”record_value”,

“pk.fields”:”id”,

“auto.create”:”true”,

“auto.evolve”:”true”,

“transforms”:”unwrap”,

“transforms.unwrap.type”: “io.debezium.transforms.UnwrapFromEnvelope”

}

}

Leave a Reply

Your email address will not be published. Required fields are marked *