[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531665#comment-17531665 ]
Martijn Visser commented on FLINK-24477: ---------------------------------------- I've just closed FLINK-27156 since that's a duplicate, but there is some relevant information from that ticket that I do would like to post here too: We're definitely looking forward to community volunteers who would like to build and maintain a MongoDB Sink. New connectors will go straight into their own dedicated repository, flink-connector-mongodb in this case. This is because we're in the process of externalizing all connectors to their own dedicated repositories. If there's someone who would like to work on this, I could get flink-connector-mongodb created. An example (still work in progress but moving forward) is the Elasticsearch connector. You can read up on that at https://github.com/apache/flink-connector-elasticsearch Let me know if there are any more questions or remarks. > Add MongoDB sink > ---------------- > > Key: FLINK-24477 > URL: https://issues.apache.org/jira/browse/FLINK-24477 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common > Reporter: Nir Tsruya > Assignee: Nir Tsruya > Priority: Minor > Labels: pull-request-available, stale-assigned > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use MongoDB as sink for my data pipeline. > *Scope:* > * Implement an asynchronous sink for MongoDB inheriting the AsyncSinkBase > class. The implementation can for now reside in its own module in > flink-connectors. > * Implement an asynchornous sink writer for MongoDB by extending the > AsyncSinkWriter. The implemented Sink Writer will be used by the Sink class > that will be created as part of this story. > * Java / code-level docs. > * End to end testing -- This message was sent by Atlassian Jira (v8.20.7#820007)