[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327118#comment-16327118
]
xymaqingxiang edited comment on FLINK-8290 at 1/16/18 1:33 PM:
---------------------------------------------------------------
The description of “client.id” is “An id string to pass to the server when
making requests. The purpose of this is to be able to track the source of
requests beyond just ip/port by allowing a logical application name to be
included in server-side request logging.” in documentation of
[kafka](https://kafka.apache.org/documentation/#consumerconfigs).
was (Author: xymaqingxiang):
The description of “client.id” is “An id string to pass to the server when
making requests. The purpose of this is to be able to track the source of
requests beyond just ip/port by allowing a logical application name to be
included in server-side request logging.” in documentation of
[kafka](https://kafka.apache.org/documentation/#consumerconfigs).
> 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
> 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)
