This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch v4.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from 0b2bf49 [hotfix] Allow manual triggering of nightly builds
new 68e9c56 [FLINK-31319][connectors/kafka] Fix kafka new source
partitionDiscoveryIntervalMs error condition check cause bounded source can not
quit
new 15b51f1 [FLINK-31620] [upsert-kafka] Flush wrapped writer
new 7e3c5a1 [FLINK-31305] Propagate producer exceptions outside of
mailbox executor so that checkpoints can correctly fail
new dd09fa9 [FLINK-31305] fix error propagation bug in WriterCallback and
use TestSinkInitContext general purpose sink testing tool
new a5df3c7 [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(-)
