/change-data-capture

Start the topology as defined in https://debezium.io/documentation/reference/stable/tutorial.html

export DEBEZIUM_VERSION=2.1 docker-compose -f docker-compose-postgres.yaml up

Start Postgres connector

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

Consume messages from a Debezium topic

docker-compose -f docker-compose-postgres.yaml exec kafka /kafka/bin/kafka-console-consumer.sh
--bootstrap-server kafka:9092
--from-beginning
--property print.key=true
--topic dbserver1.inventory.customers

docker-compose -f docker-compose-postgres.yaml exec kafka /kafka/bin/kafka-console-consumer.sh
--bootstrap-server kafka:9092
--from-beginning
--property print.key=true
--topic dbserver1.inventory.products

Modify records in the database via Postgres client

docker-compose -f docker-compose-postgres.yaml exec postgres env PGOPTIONS="--search_path=inventory" bash -c 'psql -U $POSTGRES_USER postgres'

Shut down the cluster

docker-compose -f docker-compose-postgres.yaml down