mongo-kafka
mongo-kafka copied to clipboard
mongodb
MongoDB Kafka Connector
Uses a dynamic MBean to help manage the additional metrics. Some of the metrics have been renamed to better fit as prefixes for the new metrics. The MBean naming is...
Hi, we currently have the scenario where we have to create multi version of the same document based on a key in the value and delete all versions based on...
This feature to set change stream to start at specific time. When synchronizing the data from source to destination, it will have a gap of time during exporting and importing...
[KAFKA-300](https://jira.mongodb.org/browse/KAFKA-300) Debezium 1.8 support change stream in capture.mode config. The message format for update cdc event is different from oplog mode. Other events are still working with existing code. This...
Hi, I found "null" strings in my topics and digging in the code I found that everything is stringified if the string field is not Optional. I don't want to...
Recently I'd a request from my customer where they explained that when the _id is provided in the kafka stream there's no way to convert this to ObjectId to keep...
Hi, we had the need to send tombstones on delete events to allow consumers to delete data when origin data in deleted. Currently the Source connector filters out every null...
Hi, Team! I believe, failure of Change Stream is a fatal event to MongoSource Connector users. Therefore, not the info level, but the error level log is required. In my...
I'd like to develop Custom CDC Handler for N data insert with 1 sinkData. But I can't find any base kafka connect feature about this ( kafka connect options, SMT...
When we synchronize data between two MongoDBs using multiple Kafka connectors we need to be able to skip duplicate key error but not tolerate to all other errors (ERRORS_TOLERANCE_CONFIG =...
