|
|
|
FLINK-32591
|
FLINK-31953
Update document of Kafka Source: Enable Dynamic Partition Discovery by Default in Kafka Source
|
Hongshun Wang
|
Hongshun Wang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-32021
|
FLINK-31953
Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.
|
Hongshun Wang
|
Hongshun Wang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-32020
|
FLINK-31953
Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288
|
Hongshun Wang
|
Hongshun Wang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-32019
|
FLINK-31953
EARLIEST offset strategy for partitions discoveried later based on FLIP-288
|
Hongshun Wang
|
Hongshun Wang
|
|
Closed |
Fixed
|
|
|
|
|