Create a payload.json file with: { "name" : "cluster98" , "config" : { "connector.class" : "io.debezium.connector.mysql.MySqlConnector" , "database.hostname" : "xx.xx.xx.xx" , "database.port" : "3306" , "database.user" : "debezium" , "database.password" : "xxxx" , "database.server.name" : "cluster98" , "database.history.kafka.bootstrap.servers" : "node1:9092,node2:9092,node3:9092" , "database.history.kafka.topic" : "debezium.cluster98" , "include.schema.changes" : " true " , "database.exclude.list" : "information_schema,mysql,mysql_innodb_cluster_metadata,performance_schema,sys,xxx" , "table.exclude.list" : "(.*)\\.migrations,(.*)\\.migrations_admin" , "key.converter" : "io.confluent.connect.avro.AvroConverter" , "key.converter.schema.registry.url" : "http: //node1:8081" , "value.converter" : "io.confluent.connect.avro.AvroConverter" , "value.converter.schema.registry.url" : "http: //node1:8081" , "sanitize.field.names" : " true " , "transforms" : "reroute" , "transforms.reroute.type" : "io.debezium.transforms.ByLogicalTableRouter" , "transforms.reroute.topic.regex" : "cluster(.*)\\.(.*)\\.(.*)" , "transforms.reroute.topic.replacement" : "$2.$3" , "topic.creation. default .replication.factor" : 3, "topic.creation. default .partitions" : 16, "topic.creation. default .cleanup.policy" : "compact" , "topic.creation. default .compression.type" : "lz4" } } Replace placeholders with test values (IP addresses, passwords, etc). Then call the Kafka Connect REST API: curl -s -H "Accept: application/json" -H "Content-Type: application/json" -XPOST -d @payload.json http://localhost:8083/connectors | jq Check for connector status: curl -s -XGET http://localhost:8083/connectors/cluster98/status | jq