This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c41e087 [FLINK-14935][task,runtime] Use RunnableWithException in the
Mailbox
add de44e09 [FLINK-14943][Connector/Kafka] Expose callback and related
fields to subclasses for override
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/connectors/kafka/FlinkKafkaProducer.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
