Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
kafka-3.1.0
Description
Implementation that supports unbounded and bounded modes. With a default implementation of KafkaMetadataService
Implementation that supports unbounded and bounded modes. With a default implementation of KafkaMetadataService
Fixed in apache/flink-connector-kafka:main
initial implementation of DynamicKafkaSource with bounded/unbounded support and unit/integration tests eaeb7817788a2da6fed3d9433850e10499e91852
Fix flaky tests by ensuring test utilities produce records with consistency and cleanup notify no more splits to ensure it is sent cdfa328b5ec34d711ae2c9e93de6de7565fd1db6