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)