This is an automated email from the ASF dual-hosted git repository.
bowenli86 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from eb8ff700 [FLINK-39728] Fix pauseOrResumeSplits race with unassigned
partitions
add ccb316cb [FLINK-39980] Implement split rebalance/reassignment support
in DynamicKafkaSource after metadata changes (#278)
No new revisions were added by this update.
Summary of changes:
.github/workflows/push_pr.yml | 2 +-
.../docs/connectors/datastream/dynamic-kafka.md | 6 +-
.../docs/connectors/datastream/dynamic-kafka.md | 8 +-
.../kafka/dynamic/source/DynamicKafkaSource.java | 2 +
.../enumerator/DynamicKafkaSourceEnumerator.java | 236 +++++++++++++-
.../enumerator/GlobalSplitOwnerAssigner.java | 22 ++
.../DynamicKafkaSourceEnumeratorRecoveryTest.java | 358 +++++++++++++++++++++
.../DynamicKafkaSourceEnumeratorTest.java | 7 +-
pom.xml | 2 +-
9 files changed, 620 insertions(+), 23 deletions(-)
create mode 100644
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumeratorRecoveryTest.java
