This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch v3.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from 3231933 [FLINK-30963][ci] Streamline binary URL configuration
new d484c65 [FLINK-31319][connectors/kafka] Fix kafka new source
partitionDiscoveryIntervalMs error condition check cause bounded source can not
quit
new 3691c90 [FLINK-31620] [upsert-kafka] Flush wrapped writer
new 1ad9755 [FLINK-31305] Propagate producer exceptions outside of
mailbox executor so that checkpoints can correctly fail
new fdf0854 [FLINK-31305] fix error propagation bug in WriterCallback and
use TestSinkInitContext general purpose sink testing tool
new 1b1d799 [FLINK-31363] [kafka] Add hasDataInTransaction flag in
FlinkKafkaInternalProducer
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connector-kafka/pom.xml | 8 +
.../kafka/sink/FlinkKafkaInternalProducer.java | 29 ++++
.../flink/connector/kafka/sink/KafkaWriter.java | 60 ++++++-
.../source/enumerator/KafkaSourceEnumerator.java | 2 +-
.../kafka/table/ReducingUpsertWriter.java | 9 +-
.../sink/FlinkKafkaInternalProducerITCase.java | 59 ++++++-
.../connector/kafka/sink/KafkaWriterITCase.java | 192 +++++++++++++++++----
.../source/enumerator/KafkaEnumeratorTest.java | 113 +++++++++++-
.../kafka/table/ReducingUpsertWriterTest.java | 7 +-
9 files changed, 422 insertions(+), 57 deletions(-)
