[jira] [Created] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[Shang Yuanchun (Jira)]

xymaqingxiang created FLINK-8290:
------------------------------------

             Summary: Modify clientId to groupId in flink-connector-kafka-0.8
                 Key: FLINK-8290
                 URL: https://issues.apache.org/jira/browse/FLINK-8290
             Project: Flink
          Issue Type: Improvement
            Reporter: xymaqingxiang


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:

{code:java}
private final String clientIdFormGroup;
...
this.clientIdFormGroup = config.getProperty("group.id", "flink-kafka-consumer-legacy-" + broker.id());
...
final String clientId = clientIdFormGroup;
{code}




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)