Details

    Description

      Implementation that supports unbounded and bounded modes. With a default implementation of KafkaMetadataService

      Attachments

        Activity

          martijnvisser Martijn Visser added a comment -

          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

          martijnvisser Martijn Visser added a comment - 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

          People

            mason6345 Mason Chen
            mason6345 Mason Chen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: