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
at 75368b77 [hotfix] Remove full qualifier for SinkWriter.Context in test
This branch includes the following new commits:
new 68e9c56d [FLINK-31319][connectors/kafka] Fix kafka new source
partitionDiscoveryIntervalMs error condition check cause bounded source can not
quit
new 15b51f17 [FLINK-31620] [upsert-kafka] Flush wrapped writer
new 7e3c5a16 [FLINK-31305] Propagate producer exceptions outside of
mailbox executor so that checkpoints can correctly fail
new dd09fa9a [FLINK-31305] fix error propagation bug in WriterCallback and
use TestSinkInitContext general purpose sink testing tool
new a5df3c7c [FLINK-31363] [kafka] Add hasDataInTransaction flag in
FlinkKafkaInternalProducer
new a3a21ce5 [hotfix] Update NOTICE files to reflect year 2023
new 5bb23911 [FLINK-25916][connector-kafka] Using upsert-kafka with a
flush buffer results in Null Pointer Exception
new 75368b77 [hotfix] Remove full qualifier for SinkWriter.Context in test
The 8 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.
