Hi all, I would like to start a discussion on FLIP-451[1] The proposal comes on encountering a couple of issues while working with implementers for Async Sink. The FLIP mainly proposes a new API similar to AsyncFunction and ResultFuture as well as introducing timeout handling for AsyncSink requests. The FLIP targets 1.20 with backward compatible changes and we should proceed by adding support in all supporting connector repos.
1- https://cwiki.apache.org/confluence/display/FLINK/FLIP-451%3A+Refactor+Async+Sink+API Best Regards Ahmed Hamdy
