This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from bd2fd2b2 [FLINK-39338] Fix topic name collisions in
KafkaWriterTestBase for parameterized tests
new c3f80874 [FLINK-39234][tests] Move
createNewTopicAndWaitForPartitionAssignment to a shared utils class
new 7ec6463d [FLINK-39234][tests] Wait for topic intialization in
KafkaWriterTestBase based tests
The 2 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/KafkaWriterTestBase.java | 12 ++----
.../DynamicKafkaSourceExternalContext.java | 5 ++-
.../flink/connector/kafka/testutils/KafkaUtil.java | 45 ++++++++++++++++++++++
.../connectors/kafka/KafkaTestEnvironment.java | 2 +-
.../connectors/kafka/KafkaTestEnvironmentImpl.java | 43 ++-------------------
5 files changed, 55 insertions(+), 52 deletions(-)
