skip to Main Content

I have mongodb and I need to send the changes from a certain query to kafka broker. I heard that debezium tracks changes from database and stores it to kafka. But is there a way to configure that process to store not all the changes that happen in database but only a certain ones?

2

Answers


  1. You can perform some filtering using their single message transform (SMT) Kafka Connect plugin. You can check its documentation to see if it has the features that you need: https://debezium.io/documentation/reference/stable/transformations/filtering.html

    Login or Signup to reply.
  2. Depending on the source technology you could.

    When using PostgreSQL as a source, for example, you can define which operations to include in the PG publication that is read by Debezium

    More info at the Debezium docs

    Login or Signup to reply.
Please signup or login to give your own answer.
Back To Top
Search