diff --git a/src/main/scala/pl/allegro/tech/kafka/offset/monitor/graphite/OffsetGraphiteReporter.scala b/src/main/scala/pl/allegro/tech/kafka/offset/monitor/graphite/OffsetGraphiteReporter.scala index 7c4e2b6..becd58d 100644 --- a/src/main/scala/pl/allegro/tech/kafka/offset/monitor/graphite/OffsetGraphiteReporter.scala +++ b/src/main/scala/pl/allegro/tech/kafka/offset/monitor/graphite/OffsetGraphiteReporter.scala @@ -82,6 +82,6 @@ class OffsetGraphiteReporter (pluginsArgs: String) extends com.quantifind.kafka. } def getMetricName(offsetInfo: OffsetInfo): String = { - "topic=" + offsetInfo.topic.replace(".", "_") + ".group=" + offsetInfo.group.replace(".", "_") + ".partition=" + offsetInfo.partition + ".gauge=" + "topic_" + offsetInfo.topic.replace(".", "_") + ".group_" + offsetInfo.group.replace(".", "_") + ".partition_" + offsetInfo.partition + ".gauge_" } }