[FLINK-20848] Kafka consumer ID is not specified correctly in new KafkaSource

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Qingsheng Ren
• Created: 05/Jan/21 07:02
• Updated: 28/May/21 07:06
• Resolved: 13/Jan/21 02:51

Description

In the constructor of KafkaPartitionSplitReader, subtaskId should be assigned before invoking createConsumerClientId method because this method uses subtask ID as Kafka consumer ID's suffix

Issue Links

• links to: GitHub Pull Request #14556