[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692944#comment-15692944 ]
Renkai Ge commented on FLINK-5128: ---------------------------------- I want to work for this. > 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)