Dynamic Topic Mapping in MongoDb Kafka sink

Working with Data Connectors & Integrations
1

Hi All,

Any examples on how to implement below in mongodb kafka sink,

In 1.4 you can now specify a namespace map that defines which kafka topic a namespace should be written to. For example, consider the following map:

{“Customers”: “CustomerTopic”,
“Customers.Orders”: “Orders”}
This will map all change stream documents from the Customers database to CustomerTopic. apart from any documents from the Customers.Orders namespace which map to the Orders topic.`

Thank you