This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from 40cf9994 [hotfix] Test PRs against Flink 1.17.0 and all nightly builds
against 1.17-SNAPSHOT and 1.18-SNAPSHOT
new 85bdc841 [hotfix] Refactor test util method for collecting results of
bounded query
new fc31198d [FLINK-31740] [upsert-kafka] Allow setting boundedness
options for upsert-kafka
new ffa11654 [hotfix] Refactor MockPartitionOffsetsRetriever as a common
test utility
The 3 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:
.../kafka/table/KafkaConnectorOptionsUtil.java | 2 +-
.../table/UpsertKafkaDynamicTableFactory.java | 19 +-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 72 +-------
.../connectors/kafka/table/KafkaTableITCase.java | 18 +-
.../kafka/table/KafkaTableTestUtils.java | 17 ++
.../table/UpsertKafkaDynamicTableFactoryTest.java | 157 +++++++++++++++-
.../kafka/table/UpsertKafkaTableITCase.java | 199 +++++++++++++++++++++
.../testutils/MockPartitionOffsetsRetriever.java | 102 +++++++++++
8 files changed, 494 insertions(+), 92 deletions(-)
create mode 100644
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/MockPartitionOffsetsRetriever.java
