I want to implement Outbox Pattern in our microservices using Mongo-Kafka connector, in my outbox(a MongoDB collection) I store topic data using these fields:
But how should I config mongo-kafka connector to dynamically choose the topic from the
kafka_topic field and also its values and headers from other outbox fields?
I can not find settings to do this from its config reference.
I’m also thinking about getting a fork from mongo-kafka connector repository and extend it with my custom implementation of source class or any other way.
I would greatly appreciate it if you could help me.