This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a change to branch v5.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from 5daafa34 [hotfix][docs] Add doc version data yaml
new 95c5ebeb [hotfix] Stabilize KafkaWriterFaultToleranceITCase
exception-on-unavailable tests
new 9695764f [FLINK-39699][tests] Wait for completed checkpoint stats in
KafkaSinkITCase
new a3341cc0 [FLINK-39699][tests] Wait for partitions assignment in
KafkaSinkITCase
new aebf1b57 [FLINK-39723][tests] Wait for partition assignment in
KafkaTableTestBase.createTestTopic
The 4 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:
.../connector/kafka/sink/KafkaSinkITCase.java | 66 ++++++++++++----------
.../sink/KafkaWriterFaultToleranceITCase.java | 6 ++
.../connectors/kafka/table/KafkaTableTestBase.java | 18 +-----
3 files changed, 46 insertions(+), 44 deletions(-)
