You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ma...@apache.org on 2023/10/11 07:06:50 UTC

[flink-connector-kafka] branch main updated (73f761fa -> b0f15f27)

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


    from 73f761fa [FLINK-33149][Connector/Kafka] Bump snappy-java from 1.1.8.3 to 1.1.10.5
     add b0f15f27 [FLINK-33231] [source] Properly evict offsetsToCommit cache on checkpoint complete if no offsets exist

No new revisions were added by this update.

Summary of changes:
 .../kafka/source/reader/KafkaSourceReader.java     | 21 ++++++++++++++-------
 .../kafka/source/reader/KafkaSourceReaderTest.java | 22 +++++++++++++++++++++-
 2 files changed, 35 insertions(+), 8 deletions(-)