bowenli86 opened a new pull request, #280: URL: https://github.com/apache/flink-connector-kafka/pull/280
## Summary Documents the PyFlink per-cluster starting and stopping offset initializer API for DynamicKafkaSource, following the merged FLINK-38918 implementation https://github.com/apache/flink/pull/28512 in apache/flink repo ## Changes - Added a Python tab to the Dynamic Kafka offsets example using `SingleClusterTopicMetadataService` with per-cluster starting and stopping offset initializers. - Demonstrated a per-cluster starting offset overriding the global builder default and used `set_bounded(...)` so stopping offsets apply. - Mirrored the example in the Chinese documentation tree. ## Validation - `git diff --check upstream/main...HEAD` — passed - `./mvnw -N apache-rat:check` — passed ## Notes No repository-local Markdown/Hugo docs build target exists; no production code changed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
