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)
