flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Erik van Oosten (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6928) Kafka source: default topic needs to exist
Date Thu, 15 Jun 2017 08:28:00 GMT
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)

Mime
View raw message