mongo-kafka
mongo-kafka copied to clipboard
Implemented a new id strategy in the Sink Connector
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 it consistent with the other records in the collection, checking the different Id Providers it looks like there's no implementation of the ObjectId when it's provided, as such I've implemented a custom Id Provider that receives the string either in the Key or in the Value and converts this to an ObjectId, this way the customer will keep consistency with the previous records created using standard driver.
hi, thanks for the PR @crossleyjuan , we have exactly the same need / constraints in our actual product.
Any guys in the mongodb core team can evaluate this pr / need ?
@crossleyjuan That's really great !! Waiting to be merged :)
Hi there, Any chance this PR could be reviewed soon?
Hi team, Any chance this PR could be reviewed?