From 3f11e3a8de217a38a0d8ceadaf09871c1b5a891d Mon Sep 17 00:00:00 2001 From: Michael Tamm Date: Fri, 5 Oct 2012 15:21:32 +0200 Subject: [PATCH] KAFKA-547: consumer stats MBean name includes the groupid now --- core/src/main/scala/kafka/consumer/ConsumerConnector.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/consumer/ConsumerConnector.scala b/core/src/main/scala/kafka/consumer/ConsumerConnector.scala index 94cb2f1..7c17c7a 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerConnector.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerConnector.scala @@ -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 } } -- 1.7.11.msysgit.1