You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Michal Harish (JIRA)" <ji...@apache.org> on 2016/06/05 15:24:59 UTC

[jira] [Updated] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open()

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

Michal Harish updated FLINK-4023:
---------------------------------
    Description: 
Currently, Flink queries Kafka for partition information when creating the Kafka consumer. This is done on the client when submitting the Flink job, which requires the client to be able to fetch the partition data from Kafka.


> Move Kafka consumer partition discovery from constructor to open()
> ------------------------------------------------------------------
>
>                 Key: FLINK-4023
>                 URL: https://issues.apache.org/jira/browse/FLINK-4023
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector
>            Reporter: Michal Harish
>            Priority: Minor
>              Labels: kafka, kafka-0.8
>
> Currently, Flink queries Kafka for partition information when creating the Kafka consumer. This is done on the client when submitting the Flink job, which requires the client to be able to fetch the partition data from Kafka.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)