sourceconnector.json

{
    "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"
    }
}