Case Study : Customer Service + CDC Outbox + Notification Service
Archived 2 months ago
D
direct_x_34
Script Kiddie!
End-to-end event flow for customer changes: Customer Service + CDC Outbox + Notification Service
An implementation of the Transactional Outbox Pattern with Spring Boot, Debezium, and Kafka
• Customer Service (REST API):/customers endpoints for create/update/delete/read; each operation writes an event to the outbox_event table.• Debezium + Kafka:Debezium captures changes from outbox_event via CDC and publishes them to a Kafka topic (e.g. customerdb.outbox_event).• Notification Service:Consumes outbox events from Kafka and sends email notifications via JavaMailSender based on event type.• Kafdrop (http://localhost:9000):Inspect topics and event payloads in real time through a simple web UI.
If you’d like to explore the details and review the code, check out the #GitHub repository via the link below.
Link : https://github.com/Rapter1990/cdc-debezium-outbox
An implementation of the Transactional Outbox Pattern with Spring Boot, Debezium, and Kafka
• Customer Service (REST API):/customers endpoints for create/update/delete/read; each operation writes an event to the outbox_event table.• Debezium + Kafka:Debezium captures changes from outbox_event via CDC and publishes them to a Kafka topic (e.g. customerdb.outbox_event).• Notification Service:Consumes outbox events from Kafka and sends email notifications via JavaMailSender based on event type.• Kafdrop (http://localhost:9000):Inspect topics and event payloads in real time through a simple web UI.
If you’d like to explore the details and review the code, check out the #GitHub repository via the link below.
Link : https://github.com/Rapter1990/cdc-debezium-outbox
