sohangp / outbox-pattern Goto Github PK

Hi

Problem, how do I know that messages will come to kafka? Even if debezium-connect can be temporary down.

Example
I have running all services. I create students in student app

HTTP POST http://localhost:8080/students/~/enroll

{ 
    "name": "Yan-1",
    "email": "[email protected]",
    "address": "Toronto, ON"
}

The message comes to kafka

{"schema":null,"payload":"{\"studentId\":4,\"name\":\"Yan-1\",\"email\":\"[email protected]\",\"address\":\"Toronto, ON\"}"}

Now, I stopped debezium connect. docker-compose stop debezium-connect.
Imagine a real world situation when some containers can go down.

Then I create a user.

HTTP POST http://localhost:8080/students/~/enroll

{ 
    "name": "Yan-2 ebezium is down",
    "email": "[email protected]",
    "address": "Toronto, ON"
}

The student record is created in the database. However, there is not kafka message.

Hi, thanks for this repo. I am curious about the performance. How much of a difference in the time can we expect to see in our messages being sent to Kafka with debezium; is it negligible?