kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1003; ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager; patched by Swapnil Ghike; reviewed by Jun Rao
Date Wed, 07 Aug 2013 17:20:34 GMT
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 <sghike@linkedin.com>
Authored: Wed Aug 7 10:24:21 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
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]


Mime
View raw message