mysql-debezium-source.json

{
    "name": "test-mysql-connector01",
    "config": {
        "connector.class": "io.debezium.connector.mysql.MySqlConnector",
        "tasks.max": "1",
        "database.hostname": "127.0.0.1",
        "database.port": "3306",
        "database.user": "root",
        "database.password": "",
        "database.include.list": "test-src01",
        "database.server.name": "test-server",
        "snapshot.mode": "initial",
        "database.serverTimezone": "UTC",
        "time.precision.mode": "adaptive_time_microseconds",
        "database.history.kafka.topic": "schema-changes.test-mysql-01",
        "database.history.kafka.bootstrap.servers": "localhost:9092",
        "transforms": "route",
        "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)",
        "transforms.route.replacement": "$3"
    }
}