root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

The ConsumerStats MBean name should include the groupid; patched by Michael Tamm; reviewed by Jun Rao; kafka-547 

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1396085 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jun Rao 2012-10-09 15:56:52 +00:00
parent 7294dd3333
commit 3819adc486
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/scala/kafka/consumer/ConsumerConnector.scala
View File

@ -74,7 +74,7 @@ object Consumer extends Logging {
*/ */
def create(config: ConsumerConfig): ConsumerConnector = { def create(config: ConsumerConfig): ConsumerConnector = {
val consumerConnect = new ZookeeperConsumerConnector(config) val consumerConnect = new ZookeeperConsumerConnector(config)
Utils.registerMBean(consumerConnect, consumerStatsMBeanName) Utils.registerMBean(consumerConnect, consumerStatsMBeanName + ",groupid=" + config.groupId)
consumerConnect consumerConnect
} }
@ -86,7 +86,7 @@ object Consumer extends Logging {
*/ */
def createJavaConsumerConnector(config: ConsumerConfig): kafka.javaapi.consumer.ConsumerConnector = { def createJavaConsumerConnector(config: ConsumerConfig): kafka.javaapi.consumer.ConsumerConnector = {
val consumerConnect = new kafka.javaapi.consumer.ZookeeperConsumerConnector(config) val consumerConnect = new kafka.javaapi.consumer.ZookeeperConsumerConnector(config)
Utils.registerMBean(consumerConnect.underlying, consumerStatsMBeanName) Utils.registerMBean(consumerConnect.underlying, consumerStatsMBeanName + ",groupid=" + config.groupId)
consumerConnect consumerConnect
} }
} }