Skip to content

Latest commit

 

History

History
46 lines (35 loc) · 1.36 KB

README.md

File metadata and controls

46 lines (35 loc) · 1.36 KB

debezium-outbox-pgkafka

Prerequisites

This project assumes you have the following installed on your machine:

  • Gradle
  • Docker
  • Docker-compose
  • Postman

About the project

Transactional outbox pattern

Using:

  • Spring boot & Flyway -- app framework & DB migration
  • Postgresql 11 -- database
  • Debezium Kafka Connect & Postgresql connector -- debezium wrapped kafka connect
  • Zookeeper
  • Kafka -- event store

This project uses pgoutput as the logical decoding output plugin.

Content-Based Routing

This project also uses the type column in outbox table to route message into different topic.

E.g:
Type 'TodoCreatedEvent' will get published to 'sampleproject.todos.todo-created-event' 
Type 'TodoDeletedEvent' will get published to 'sampleproject.todos.todo-deleted-event'

Routing is done with groovy expression. This project uses an image with groovy-jsr223 added to classpath as the base image.
https://hub.docker.com/r/fernandochristyanto/debezium-connect-base

How to run

  1. Set up a static ip on local machine
sudo ifconfig lo0 alias 192.168.99.3
  1. Change directory to todo-service and run ./gradlew clean build
  2. In root directory, run docker-compose up
  3. Import the postman collection
  4. Hit the Connector Registration POST endpoint
  5. Start doing transactions by inserting / deleting todos