//source connector:
curl -i -X POST  -H  "Content-Type:application/json" http://localhost:8083/connectors/  -d '{

"name": "test_data-bill_rating_rule_def-connector-souces", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "database.hostname": "127.0.0.1", "database.port": "3306", "database.user": "platform", "database.password": "platform@0708", "database.server.id": "169798195", "database.server.name": "test_data_connector", "database.whitelist": "test_data", "table.whitelist": "test_data.bill_rating_rule_def", "database.history.kafka.bootstrap.servers": "broker161:9092,broker162:9092,broker163:9092,broker166:9092,broker164:9092,cdh6-slave1:9092,cmhk-b-sl-236:9092", "database.history.kafka.topic": "dbhistory.inventory", "include.schema.changes": "true", "database.history.skip.unparseable.ddl": "true", "decimal.handling.mode": "string", "event.deserialization.failure.handling.mode:": "ERROR" }}' 

//sink connector: curl -i -X POST -H "Content-Type:application/json" http://localhost:8083/connectors/ -d '