[FLINK-8290] Allow setting clientId in flink-connector-kafka-0.8

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7.0
• Labels: pull-request-available
• Assignee: xymaqingxiang
• Reporter: xymaqingxiang
• Created: 19/Dec/17 02:35
• Updated: 15/Aug/18 13:53
• Resolved: 15/Aug/18 13:53

Description

Now the Clientid that consumes the all topics are constant("flink-kafka-consumer-legacy-" + broker.id()), and it is not easy for us to look at kafka's log, so I recommend that it be modified to groupid.

We can modify the SimpleConsumerThread.java file, as shown below:

private final String clientId;
...
this.clientId = config.getProperty("group.id", "flink-kafka-consumer-legacy-" + broker.id());
...

Issue Links

• links to: GitHub Pull Request #5304
• links to: GitHub Pull Request #5304