Erik van Oosten created FLINK-6928:
--------------------------------------
Summary: Kafka source: default topic needs to exist
Key: FLINK-6928
URL: https://issues.apache.org/jira/browse/FLINK-6928
Project: Flink
Issue Type: Bug
Components: Kafka Connector
Affects Versions: 1.2.1, 1.3.0
Reporter: Erik van Oosten
When using a Kafka source, the defaultTopic needs to exist even when it is
never used. It would be nice if fetching partition information for the default
topic would be delayed until the moment a topic is actually used.
Cause: {{FlinkKafkaProducerBase.open}} fetches partition information for the
default topic.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
