[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrey Zagrebin reassigned FLINK-8290: -------------------------------------- Assignee: Andrey Zagrebin (was: xymaqingxiang) > 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 > Assignee: Andrey Zagrebin > Priority: Major > > 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 clientId; > ... > this.clientId = config.getProperty("group.id", "flink-kafka-consumer-legacy-" > + broker.id()); > ... > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)