This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8a694ca [FLINK-25702][Kafka] Use the configure feature provided by
the kafka Serializer/Deserializer
add d8a031c [FLINK-24041][connector] Fixing reversed insertion of failed
requests
No new revisions were added by this update.
Summary of changes:
.../base/sink/writer/AsyncSinkWriter.java | 4 ++-
.../base/sink/writer/AsyncSinkWriterTest.java | 33 +++++++++++++++++++++-
2 files changed, 35 insertions(+), 2 deletions(-)
