kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1396085 - /incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala
Date Tue, 09 Oct 2012 15:56:52 GMT
Author: junrao
Date: Tue Oct  9 15:56:52 2012
New Revision: 1396085

URL: http://svn.apache.org/viewvc?rev=1396085&view=rev
Log:
The ConsumerStats MBean name should include the groupid; patched by Michael Tamm; reviewed
by Jun Rao; kafka-547

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala?rev=1396085&r1=1396084&r2=1396085&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala Tue Oct
 9 15:56:52 2012
@@ -74,7 +74,7 @@ object Consumer extends Logging {
    */
   def create(config: ConsumerConfig): ConsumerConnector = {
     val consumerConnect = new ZookeeperConsumerConnector(config)
-    Utils.registerMBean(consumerConnect, consumerStatsMBeanName)
+    Utils.registerMBean(consumerConnect, consumerStatsMBeanName + ",groupid=" + config.groupId)
     consumerConnect
   }
 
@@ -86,7 +86,7 @@ object Consumer extends Logging {
    */
   def createJavaConsumerConnector(config: ConsumerConfig): kafka.javaapi.consumer.ConsumerConnector
= {
     val consumerConnect = new kafka.javaapi.consumer.ZookeeperConsumerConnector(config)
-    Utils.registerMBean(consumerConnect.underlying, consumerStatsMBeanName)
+    Utils.registerMBean(consumerConnect.underlying, consumerStatsMBeanName + ",groupid="
+ config.groupId)
     consumerConnect
   }
 }



Mime
View raw message