This example shows how to implement an integration test for your CDC set-up using Testcontainers. It spins up Postgres, Apache Kafka and Kafka Connect (including the Debezium) connectors, deploys an instance of the Debezium Postgres connector and runs some assertions against expected change events on the corresponding Kafka topic.
Please refer to the Debezium documentation to learn more about its Testcontainers support.
- Java 11 development environment
- Local Docker installation
mvn clean package