[FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink#28512

bowenli86 wants to merge 5 commits into

apache:masterapache/flink:masterfrom

bowenli86:dev/bowenli/codex/flink-38918-pyflink-per-cluster-offsetbowenli86/flink-dev:dev/bowenli/codex/flink-38918-pyflink-per-cluster-offsetCopy head branch name to clipboard