From 027a8ba0a67c1b9126cafbe15e4e96aa2fda4c20 Mon Sep 17 00:00:00 2001 From: Dong Lin Date: Tue, 16 Jun 2015 14:56:37 -0700 Subject: [PATCH] KAFKA-2278; JmxTool should support querying all objects when object-name is omitted --- core/src/main/scala/kafka/tools/JmxTool.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/tools/JmxTool.scala b/core/src/main/scala/kafka/tools/JmxTool.scala index c2b2030..d335b3e 100644 --- a/core/src/main/scala/kafka/tools/JmxTool.scala +++ b/core/src/main/scala/kafka/tools/JmxTool.scala @@ -97,8 +97,9 @@ object JmxTool extends Logging { val numExpectedAttributes: Map[ObjectName, Int] = attributesWhitelistExists match { case true => queries.map((_, attributesWhitelist.get.size)).toMap - case false => names.map((name: ObjectName) => - (name, mbsc.getMBeanInfo(name).getAttributes().map(_.getName).size)).toMap + case false => names.map{(name: ObjectName) => + val mbean = mbsc.getMBeanInfo(name) + (name, mbsc.getAttributes(name, mbean.getAttributes.map(_.getName)).size)}.toMap } // print csv header -- 1.7.9.5