spring-boot-debezium-db-kafka
Spring-Boot-Debezium-Kafka-PostgreSQL Relationship
Installation
- First,Configure docker-compose.yml
- Second,Write Db-Kafka configuration to json file.
- Third,Designed .sh file for DB-Kafka configuration file and Kafka-Connector
Using
- First,docker-compose up -d
- Second
sh connectionCommand.sh
- Third, Get Kafka-Drop and Looking heatbeat connection
- Fourth,Open Spring Boot Project and Post a Request
- Fifth,Get Kafka-Drop and Lookind our cdc connection
- Sixth Click our cdc connection topics and looking View Messages
-
If we do not want to see null in the Update request, we enter this command
ALTER TABLE public.vehicles REPLICA IDENTITY FULL