[FLINK-19133] User provided kafka partitioners are not initialized correctly

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.11.1
• Fix Version/s: 1.12.0, 1.11.2
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 03/Sep/20 12:32
• Updated: 18/Sep/20 06:48
• Resolved: 06/Sep/20 16:19

Description

Reported in the ML: https://lists.apache.org/thread.html/r94275a7314d44154eb1ac16237906e0f097e8a9d8a5a937e8dcb5e85%40%3Cdev.flink.apache.org%3E

If a user provides a partitioner in combination with SerializationSchema it is not initialized correctly and has no access to the parallel instance index or number of parallel instances.

Issue Links

• is duplicated by: FLINK-19285 Kafka sql connector fixed partitioner not work
• is duplicated by: FLINK-19239 FlinkKafkaProducer
• links to: GitHub Pull Request #13326