Skip to content

Experiment with Kafka, Debezium. Source Connectors: Monitor MySQL & MongoDb changes, push messages to Kafka. springboot service: Listen to Kafka.

Notifications You must be signed in to change notification settings

seyyedBagherMusavi/debezium

Repository files navigation

Spring Boot Debezium MongoDB and MySQL CDC

This repository provides a Spring Boot application that demonstrates Change Data Capture (CDC) using Debezium with MongoDB and MySQL databases. It showcases how to capture and process real-time database changes using Debezium connectors in a Spring Boot application.

Prerequisites

Before running the application, ensure you have the following software installed:

  • Java Development Kit (JDK) 11 or higher
  • Apache Maven
  • Docker and Docker Compose

Setup

  1. Clone the repository
  2. Navigate to the project directory
  3. create custom mongo docker
docker build -t  mongoex:1.0 .

4.Start the MongoDB and MySQL containers using Docker Compose:

docker-compose up -d

5.Run the application 6.Run connectors command

sh connectionCommand.sh

change data manually and get event in UserConsumer class mysql&mongo

About

Experiment with Kafka, Debezium. Source Connectors: Monitor MySQL & MongoDb changes, push messages to Kafka. springboot service: Listen to Kafka.

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published