[jira] [Created] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

[Shang Yuanchun (Jira)]

Tzu-Li (Gordon) Tai created FLINK-5128:
------------------------------------------

             Summary: Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set
                 Key: FLINK-5128
                 URL: https://issues.apache.org/jira/browse/FLINK-5128
             Project: Flink
          Issue Type: Improvement
          Components: Kafka Connector
            Reporter: Tzu-Li (Gordon) Tai
            Priority: Minor


The fetched partitions list is only used when calling {{open(...)}} for a user supplied custom partitioner in {{FlinkKafkaProducer}}.

Therefore, we can actually only fetch the partition list if the user used a partitioner (right now we always do the partition fetching).



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