This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b842230 [FLINK-23949][runtime][checkpoint] fix first incremental
checkpoint after a savepoint will degenerate into a full checkpoint
new bf3df16 [FLINK-24277][connector/kafka] Add configuration for
committing offset on checkpoint and disable it if group ID is not specified
new 7249e0d [FLINK-24277][connector/kafka] Add
OffsetsInitializerValidator interface for validating offset initializer in
KafkaSourceBuilder
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:
.../flink/connector/kafka/source/KafkaSource.java | 6 +
.../connector/kafka/source/KafkaSourceBuilder.java | 43 +++++-
.../connector/kafka/source/KafkaSourceOptions.java | 6 +
.../initializer/OffsetsInitializerValidator.java | 19 ++-
.../ReaderHandledOffsetsInitializer.java | 17 ++-
.../initializer/SpecifiedOffsetsInitializer.java | 22 ++-
.../source/reader/KafkaPartitionSplitReader.java | 24 ++--
.../kafka/source/reader/KafkaSourceReader.java | 17 +++
.../kafka/source/KafkaSourceBuilderTest.java | 156 ++++++++++++++++++++-
.../connector/kafka/source/KafkaSourceITCase.java | 19 +++
.../kafka/source/reader/KafkaSourceReaderTest.java | 36 ++++-
11 files changed, 332 insertions(+), 33 deletions(-)
copy
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/messages/MessageDeserializer.java
=>
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerValidator.java
(61%)
