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

Posted to issues@flink.apache.org by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/07/27 07:23:20 UTC

[jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

    [ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395169#comment-15395169 ] 

Tzu-Li (Gordon) Tai commented on FLINK-2510:
--------------------------------------------

Related: FLINK-4023 and FLINK-4155.
Will be fixing this along with Kafka partition discovery for the consumer in FLINK-4022.

> KafkaConnector should access partition metadata from master/cluster
> -------------------------------------------------------------------
>
>                 Key: FLINK-2510
>                 URL: https://issues.apache.org/jira/browse/FLINK-2510
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming Connectors
>    Affects Versions: 0.10.0
>            Reporter: Stephan Ewen
>            Priority: Minor
>
> Currently, the Kafka connector assumes that it can access the partition metadata from the client. There may be setups where this is not possible, and where the access needs to happen from within the cluster (due to firewalls).



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