$ make up

$ curl -H "Accept:application/json" localhost:8083

{"version":"3.0.0","commit":"8cb0a5e9d3441962","kafka_cluster_id":"A4Fi476dTauyDQw9Kv0EjQ"}

$ curl -H "Accept:application/json" localhost:8083/connectors/

[]

$ curl -i -X POST -H "Accept:application/json" -H  "Content-Type:application/json" http://localhost:8083/connectors/ -d @register-connector.json

$ curl -H "Accept:application/json" localhost:8083/connectors/

["ms_dms-connector"]

$ curl -i -X GET -H "Accept:application/json" localhost:8083/connectors/ms_dms-connector

HTTP/1.1 200 OK
Date: Fri, 04 Feb 2022 16:54:12 GMT
Content-Type: application/json
Content-Length: 558
Server: Jetty(9.4.43.v20210629)

{"name":"ms_dms-connector","config":{"connector.class":"io.debezium.connector.mysql.MySqlConnector","database.allowPublicKeyRetrieval":"true","database.user":"root","database.server.id":"1","tasks.max":"1","database.history.kafka.bootstrap.servers":"kafka:9092","database.history.kafka.topic":"schema-changes.ms_dms","database.server.name":"dms-local","database.port":"3306","database.hostname":"mysql","database.password":"root","name":"ms_dms-connector","database.include.list":"ms_dms"},"tasks":[{"connector":"ms_dms-connector","task":0}],"type":"source"}

$ docker-compose exec kafka /kafka/bin/kafka-console-consumer.sh \
 --bootstrap-server kafka:9092 \
 --from-beginning \
 --property print.key=true \
 --topic dms-local.ms_dms.user

$ docker-compose exec mysql mysql -u root -proot ms_dms -e "INSERT INTO user (name, delete_flag) VALUES ('sample_user1', 0);"

$ npm run start

$ cd /path/to/dms-local-develop
$ docker-compose exec postgres psql -U ikki pg_dms

pg_dms=# SELECT * FROM member;

 user_id |     name     |          created_at
---------+--------------+-------------------------------
       1 | sample_user1 | 2022-03-14 00:06:00.096674+00
(1 row)

pg_dms=# SELECT * FROM "user";

 id |          created_at
----+-------------------------------
  1 | 2022-03-14 00:06:00.096674+00
(1 row)

$ make down

$ make clean