[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17431044#comment-17431044 ]
ZhuoYu Chen edited comment on FLINK-24477 at 10/20/21, 8:11 AM: ---------------------------------------------------------------- [~fabian.paul] [~nir.tsruya] , I am very interested in this,{color:#333333}because I have realized Mongo data based on AsyncSinkBase in my work and have gained certain experience. I hope you can assign this task to me{color}. was (Author: monster#12): [~fabian.paul] [~nir.tsruya] , I am very interested in this,{color:#333333}, because I have realized Mongo data based on AsyncSinkBase in my work and have gained certain experience. I hope you can assign this task to me{color}. > 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 > > 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.3.4#803005)