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)
