You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/01/16 13:34:00 UTC
[jira] [Comment Edited] (FLINK-8290) Modify clientId to groupId in
flink-connector-kafka-0.8
[ 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)