Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
{
"name":"inventory-connector-mssql",
"config":{
"connector.class":"io.debezium.connector.sqlserver.SqlServerConnector",
"database.user":"sa",
"database.dbname":"inventory",
"database.history.kafka.bootstrap.servers":"my-cluster-kafka-bootstrap:9092",
"database.history.kafka.topic":"schema-changes.inventory",
"transforms":"route",
"database.server.name":"mssql1",
"database.port":"1433",
"transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.route.regex":"([^.]+)\\.([^.]+)\\.([^.]+)",
"database.hostname":"mssql",
"database.password":"Password!",
"name":"inventory-connector-mssql",
"database.whitelist":"inventory",
"table.whitelist":"dbo.customers",
"transforms.route.replacement":"inventory.$3"
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment