DamDev
Reputation: 125
Enhance Debezium message sent to Apache Kafka with current logged in user identifier
I want to implement Debezium into my application to capture all the changes in selected tables in database (MSSQL). I do not have userId column in any table. Is it possible to intercept the message sent by Debezium to Apache Kafka and enhance it with the currently logged in user identifier?
I can't add userId (eg.: lastUpdatedBy) to the tables due to expected enormous amount of data
Upvotes: 0
Views: 26
Answers (0)
Related Questions
- Debezium docker with connect table.include.list not working
- Postgres debezium connector changes are not showing up under topic messages
- Debezium transforms 1GB database to 100GBs topic storage
- Streaming Database(mariadb) Changes into another database table using apache-kafka and debezium connector
- Debezium connector with TimescaleDB extension
- How to guarantee the topic events order generated by debezium, stored in kafka and sent to spark?
- Can Debezium Capture Changes of a Postges Materialized View