Updated Branches: refs/heads/0.8 9753d15ef -> e7a546b67
kafka-1003; ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager; patched by Swapnil Ghike; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e7a546b6 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e7a546b6 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e7a546b6 Branch: refs/heads/0.8 Commit: e7a546b67cdcdcbb1071ed805a4e4177cbbc15ff Parents: 9753d15 Author: Swapnil Ghike <[email protected]> Authored: Wed Aug 7 10:24:21 2013 -0700 Committer: Jun Rao <[email protected]> Committed: Wed Aug 7 10:24:21 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/e7a546b6/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala index 71ae640..b286312 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala @@ -39,7 +39,7 @@ class ConsumerFetcherManager(private val consumerIdString: String, private val config: ConsumerConfig, private val zkClient : ZkClient) extends AbstractFetcherManager("ConsumerFetcherManager-%d".format(SystemTime.milliseconds), - config.groupId, 1) { + config.clientId, 1) { private var partitionMap: immutable.Map[TopicAndPartition, PartitionTopicInfo] = null private var cluster: Cluster = null private val noLeaderPartitionSet = new mutable.HashSet[TopicAndPartition]
