/kafka-debezium-data-streaming

This project showcases the use of Kafka connectors for real-time data streaming from Postgres databases using Spring Boot. Two branches are included, one for JSON converter and another for Avro converter."

Primary LanguageJava

Logo

CAPTURE DATA CHANGE

Playing around with Capture Data Change using Debezium
Explore the docs »

View Demo · Report Bug · Request Feature

Table of Contents
  1. About The Project
  2. Getting Started
  3. Usage
  4. Resources
  5. Authors

Spring Boot Kafka Postgres Connectors

About The Project

This repository contains two Spring Boot applications that demonstrate the use of Debezium Postgres and JDBC Sink connectors for data streaming from a Postgres database to Kafka using both JSON and Avro converters.

Built with

Getting Started

These instructions will get you a copy of the project up and running on your local machine for development and testing purposes.

Prerequisites

  • Docker
  • Docker Compose
  • Java 8 or higher

Branches

  • CDC-JSON_CONVERTER branch: Demonstrates the use of JSON converter for data streaming.
  • CDC-AVRO_CONVERTER branch: Demonstrates the use of Avro converter for data streaming.

Installation

installation-gif
  1. Clone the repository.

git clone https://github.com/Cherni-Oussama/kafka-debezium-data-streaming.git

  1. Checkout for the specifific branch you want to test git checkout CDC-JSON_CONVERTER or git checkout CDC-AVRO_CONVERTER

Usage

  1. Build the project. docker compose up.

  2. Verify that all containers are up. docker ps or you could check them from Docker Desktop

  3. Navigate to the Upstream application Swagger page and try to create new Company or Employee http://localhost:8010/swagger-ui/index.html#/employee-controller/addEmployee

  4. Verify that data is being streamed from the Postgres databases to Kafka.

  • connect to kafka container : In CMD docker exec -it kafka bash
  • list the topics created : kafka-topics --bootstrap-server localhost:9092 --list
  • consumer the messages created in the created topic : kafka-console-consumer --bootstrap-server localhost:9092 --topic topicName --from-beginning
  1. Verify that data is being streamed from the kafka to postgres sink database.
  • connect to postgres sink database : docker exec -it postgres-sink-db
  • Authentification: psql -U postgres
  • list the created tables \dt.

Resources

Authors