This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c9995a9 [FLINK-24317][python][tests] Optimize the implementation of
Top2 in test_flat_aggregate
new f0bd873 [FLINK-24277][connector/kafka] Add configuration for
committing offset on checkpoint and disable it if group ID is not specified
new c7c34ed [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:
docs/content/docs/connectors/datastream/kafka.md | 1 +
.../flink/connector/kafka/source/KafkaSource.java | 5 +
.../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 | 44 +++++-
12 files changed, 340 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%)
