[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474736#comment-13474736 ]
Yang Ye commented on KAFKA-537: ------------------------------- By exposing clientId to ConsumerConfig, different consumers can specify their own clientId's. So that we will be able to log correct client of kafka (various kind of services) Also this jira makes the correlationId meaningful (it's not used before). This is supposed to indicate a request-response correlation between a client and the server > expose clientId and correlationId in ConsumerConfig > --------------------------------------------------- > > Key: KAFKA-537 > URL: https://issues.apache.org/jira/browse/KAFKA-537 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8 > Reporter: Jun Rao > Assignee: Yang Ye > Labels: bugs, newbie > Fix For: 0.8 > > Attachments: kafka_537_v1.diff, kafka_537_v2.diff > > Original Estimate: 24h > Remaining Estimate: 24h > > We need to expose clientId and correlationId in ConsumerConfig and use it > properly in AbstractFetcherThread. For follower fetchers, we should set the > clientId to a special string, something list "follower". -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira