[jira] [Created] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery

[Shang Yuanchun (Jira)]

Till Rohrmann created FLINK-8990:
------------------------------------

             Summary: End-to-end test: Dynamic Kafka partition discovery
                 Key: FLINK-8990
                 URL: https://issues.apache.org/jira/browse/FLINK-8990
             Project: Flink
          Issue Type: Sub-task
          Components: Kafka Connector, Tests
            Reporter: Till Rohrmann


We should add an end-to-end test which verifies the dynamic partition discovery of Flink's Kafka connector. We can simulate it by reading from a Kafka topic to which we add partitions after the job started. By writing to these new partitions it should be verifiable whether Flink noticed them by checking the output for completeness.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)