This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4bde1c9 [FLINK-20194] Fix Kafka offset commit to coorectly handle the
following cases: 1. The SplitFetcher has exited. 2. The offsets to be committed
is empty. 3. The offsets commit for finished splits.
add 5576194a [FLINK-19996][kafka] Add IT case for Debezium + Kafka +
temporal join
No new revisions were added by this update.
Summary of changes:
.../connectors/kafka/table/KafkaTableITCase.java | 145 ++++++++++++++++++++-
.../src/test/resources/product_changelog.txt | 6 +
2 files changed, 150 insertions(+), 1 deletion(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/resources/product_changelog.txt
