You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/02/02 14:56:20 UTC

[GitHub] [flink] dawidwys commented on issue #7877: [FLINK-11320][Connectors / Kafka] Support user callback in Kafka sink

dawidwys commented on issue #7877: [FLINK-11320][Connectors / Kafka] Support user callback in Kafka sink
URL: https://github.com/apache/flink/pull/7877#issuecomment-581143279
 
 
   Hi @Salatich ,
   Thank you for your contribution. This is a major new feature to the Public API of Kafka connector. Such features require a proper design and consensus in the community that we want to support it. 
   
   To name a few problems with the callback: When is the callback called? What guarantees do we give for that user callback? How does it interplay with TwoPhaseCommitSink?
   
   I will close the PR for now. If you are still interested in adding that feature, please reach out to the dev mailing list first or get an approval from a committer in the corresponding JIRA ticket.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services