[ https://issues.apache.org/jira/browse/FLINK-26751 ]
Almog Tavor deleted comment on FLINK-26751:
-------------------------------------
was (Author: almogtavor):
[~martijnvisser] Maybe I just didn't understand something right. Currently, the
Kafka sink isn't implementing `AsyncSinkBase`, and doesn't seem to use the
`Future` that's returned by `KafkaProducer.send()`. Is it considered an async
sink? And if it does, I'd like to understand how, if you can elaborate.
> [FLIP-171] Kafka implementation of Async Sink
> ---------------------------------------------
>
> Key: FLINK-26751
> URL: https://issues.apache.org/jira/browse/FLINK-26751
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Kafka
> Reporter: Almog Tavor
> Priority: Major
>
> *User stories:*
> As a Flink user, I’d like to use Kafka as a sink for my data pipeline,
> asynchronously.
> *Scope:*
> * Implement an asynchronous sink for Kafka by inheriting the AsyncSinkBase
> class. The implementation can reside in the Kafka module in flink-connectors.
> h2. References
> More details to be found
> [https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink]
> h4.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
