[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15328831#comment-15328831
]
Tzu-Li (Gordon) Tai commented on FLINK-4023:
--------------------------------------------
https://issues.apache.org/jira/browse/FLINK-4069
The above is a duplicate issue for this JIRA opened after this one. I'm
referencing the link here since the description in FLINK-4069 covers additional
information on the problem, as well as link to a related discussion thread on
mailing list.
> 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
> which may only be accessible from the cluster environment where the tasks
> will be running. Moving the partition discovery to the open() method should
> solve this problem.
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
