[
https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27156.
----------------------------------
Resolution: Duplicate
Duplicate of FLINK-24477
> [FLIP-171] MongoDB implementation of Async Sink
> -----------------------------------------------
>
> Key: FLINK-27156
> URL: https://issues.apache.org/jira/browse/FLINK-27156
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Common
> Reporter: Almog Tavor
> Priority: Major
>
> *User stories:*
> I’d like to use MongoDB as a sink for my data pipeline and I think it'll be
> appropriate if it would inherit AsyncSinkBase.
> *Scope:*
> * Implement an asynchronous sink for MongoDb by inheriting the AsyncSinkBase
> class. The implementation can for now reside in its own module in
> flink-connectors, or maybe we can open a dedicated repository.
> * Implement an asynchronous sink writer for MongoDb by extending the
> AsyncSinkWriter. The implementation must deal with failed requests and retry
> them. The implementation should batch multiple requests The implemented Sink
> Writer will be used by the Sink class that will be created as part of this
> story. I'm currently looking for the right object in the Async MongoDb client
> that will represent the request.
> h2. References
> More details to be found
> [https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink]
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
