diff --git a/core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala b/core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala
index 63cf1bd..b54507c 100644
--- a/core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala
+++ b/core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala
@@ -54,14 +54,16 @@ trait KafkaMetricsGroup extends Logging {
 
     nameBuilder.append(":type=")
 
-    nameBuilder.append(typeName)
+    nameBuilder.append((if (tags.contains("allTopics")) "Aggregate" else "") + typeName)
 
     if (name.length > 0) {
       nameBuilder.append(",name=")
       nameBuilder.append(name)
+
     }
 
-    KafkaMetricsGroup.toMBeanName(tags).map(mbeanName => nameBuilder.append(",").append(mbeanName))
+    KafkaMetricsGroup.toMBeanName(tags.filter { case(key, value) => key != "allTopics" })
+      .map(mbeanName => nameBuilder.append(",").append(mbeanName))
 
     new MetricName(group, typeName, name, null, nameBuilder.toString())
   }