[FLINK-16634] The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Won't Fix
• Affects Version/s: 1.10.0
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-major pull-request-available stale-assigned
• Assignee: Unassigned
• Reporter: Jiangjie Qin
• Created: 17/Mar/20 10:42
• Updated: 16/Oct/23 12:11
• Resolved: 16/Oct/23 12:11

Description

The PartitionDiscoverer creates a KafkaConsumer using the client.id from the user provided properties. This may cause the MBean to collide with the fetching KafkaConsumer. The PartitionDiscoverer should use a unique client.id instead, such as "PartitionDiscoverer-RANDOM_LONG"

Issue Links

• links to: GitHub Pull Request #16439