[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16572626#comment-16572626
]
xymaqingxiang commented on FLINK-8290:
--------------------------------------
Hi, *all*
[group.id|http://group.id/] is a concept of kafka, used to describe consumers
property, its official description is "A string that uniquely identifies the
group of consumer processes to which this consumer belongs. By setting the same
group id multiple processes indicate that they are all part of the same
consumer group".
[client.id|http://client.id/] is a concept of SimpleConsumer, its official
descriptionis "The client id is a user-specified string sent in each request to
help trace calls. It should logically identify the application making the
request.". like this, [kafka
documentation|https://kafka.apache.org/documentation/]
!https://mail.google.com/mail/u/0?ui=2&ik=4365074462&attid=0.1&permmsgid=msg-a:r-5049515360704170079&th=16517a104555e5fb&view=fimg&sz=w1600-h1000&attbid=ANGjdJ9SfqqNzA50y7EDw4YMWcszL-eBrPbSpz50MbuXJjH1nI-wsVrtNw7lat5iFSi7PtVz8-eqRpldUYEHpbQQkOYhDp4PEJI9xNoP6qLeKBezQHuVwECpQm4FQtc&disp=emb&realattid=ii_jkkl3yrt1|width=562,height=102!
thanks.
> 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: xymaqingxiang
> Priority: Major
> Labels: pull-request-available
>
> 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)
