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

["Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tzu-Li (Gordon) Tai closed FLINK-8990.
--------------------------------------

> 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
>            Assignee: Tzu-Li (Gordon) Tai
>            Priority: Major
>             Fix For: 1.5.0
>
>
> 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)