mongo-kafka
mongo-kafka copied to clipboard
mongodb
MongoDB Kafka Connector
Add an exception to the SimplifiedJson settings provider to output standard-type UUIDs as typical hexidecimal-string format via `.asUuid().toString()` BsonBinary functions. UUID v3 values will still output as straight Base64 toString...
I have added a new output format to allow for easy implementation of the outbox pattern used with micro services when database updates need to be in sync with messages...
This PR adds support for exactly-once semantics in the source connector, which was described in [KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceConnectors-ConnectorAPIexpansions) and shipped in [Kafka Connect 3.3.0](https://archive.apache.org/dist/kafka/3.3.0/RELEASE_NOTES.html). To test this PR beyond the existing test...
## Updates: - Create a new toggle (`isUseFilterInValueDoc`) in the `MongoDbUpdate` to enable using the `filter` field provided by Debezium. - Create a new class (`MongoDbUniqueFieldHandler`) to provide default operations...
Allows for the Mongo filter opreation to be set to the exact key coming from the key doc rather than having a superfluous _id key. This is needed for a...
Implements a plug point for injecting a custom credential provider in the mongo client for sink and source connectors.
When we use custom config providers, user specified configs are replaced with config provider provided values. Current mongo source/sink connectors try to validate connection uri attribute using user specified config.
I extracted upsert from sink strategies to the topic configuration. Because I needed the ability to turn it off.
I've added operation types from MongoDB change events reference : https://www.mongodb.com/docs/manual/reference/change-events/
