You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/04 11:03:00 UTC

[jira] [Commented] (FLINK-24477) Add MongoDB sink

    [ 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)