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] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist
Date Thu, 15 Jun 2017 08:29:00 GMT

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

Erik van Oosten updated FLINK-6928:
-----------------------------------
    Summary: Kafka sink: default topic should not need to exist  (was: Kafka source: default
topic should not need to exist)

> Kafka sink: default topic should not need 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.3.0, 1.2.1
>            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