[FLINK-6288] FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Connectors / Kafka
• Assignee: Fang Yong
• Reporter: Tzu-Li (Gordon) Tai
• Created: 10/Apr/17 13:38
• Updated: 19/May/17 06:46
• Resolved: 19/May/17 06:46

Description

The FlinkKafkaProducerBase supports routing records to topics besides the default topic, but the custom Partitioner interface does not follow this semantic.

The partitioner is always invoked the partition method with the number of partitions in the default topic, and not the number of partitions of the current targetTopic.

Issue Links

• links to: GitHub Pull Request #3766
• links to: GitHub Pull Request #3901