Add topic name as a new field into Mongo

Kafka Connect
1

I have some topics with schema such as: { “data”: {}}
I want to transform this schema into: {“data”: {}, “source”: “topic name”} (source is based on each topic name).
Do you guys have any solution for this?
Please give me some advice.
Thank you.

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.