Change Data Capture (CDC) with Embedded Debezium and SpringBoot

Blog URL: https://medium.com/@sohan_ganapathy/change-data-capture-cdc-with-embedded-debezium-and-springboot-6f10cd33d8ec

Prerequisites

• Docker
• Docker Compose

Installing required tools

Once the prerequisites are installed, run the command.

export DEBEZIUM_VERSION=2.4
export DEBEZIUM_CONNECTOR_VERSION=2.4.0.Alpha2
docker-compose up -d

Student table

CREATE TABLE public.student
(
    id integer NOT NULL,
    address character varying(255),
    email character varying(255),
    name character varying(255),
    CONSTRAINT student_pkey PRIMARY KEY (id)
);

Starting the SpringBoot application

Go to the folder student-cdc-relay, run the command

mvn spring-boot:run

Scripts to Insert, Update and Delete a record on Postgres

INSERT INTO STUDENT(ID, NAME, ADDRESS, EMAIL) VALUES('1','Jack','Dallas, TX','[email protected]');

UPDATE STUDENT SET EMAIL='[email protected]', NAME='Jill' WHERE ID = 1; 

DELETE FROM STUDENT WHERE ID = 1;

Elasticsearch commands to test if CDC worked !

curl -X GET http://localhost:9200/student/student/1?pretty=true