Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 0 additions & 32 deletions core/src/main/scala/kafka/utils/ToolsUtils.scala
Original file line number Diff line number Diff line change
Expand Up @@ -17,11 +17,8 @@
package kafka.utils

import joptsimple.OptionParser
import org.apache.kafka.common.{Metric, MetricName}
import org.apache.kafka.server.util.CommandLineUtils

import scala.collection.mutable

object ToolsUtils {

def validatePortOrDie(parser: OptionParser, hostPort: String): Unit = {
Expand All @@ -37,35 +34,6 @@ object ToolsUtils {
CommandLineUtils.printUsageAndExit(parser, "Please provide valid host:port like host1:9091,host2:9092\n ")
}

/**
* print out the metrics in alphabetical order
* @param metrics the metrics to be printed out
*/
def printMetrics(metrics: mutable.Map[MetricName, _ <: Metric]): Unit = {
var maxLengthOfDisplayName = 0

val sortedMap = metrics.toSeq.sortWith( (s,t) =>
Array(s._1.group(), s._1.name(), s._1.tags()).mkString(":")
.compareTo(Array(t._1.group(), t._1.name(), t._1.tags()).mkString(":")) < 0
).map {
case (key, value) =>
val mergedKeyName = Array(key.group(), key.name(), key.tags()).mkString(":")
if (maxLengthOfDisplayName < mergedKeyName.length) {
maxLengthOfDisplayName = mergedKeyName.length
}
(mergedKeyName, value.metricValue)
}
println(s"\n%-${maxLengthOfDisplayName}s %s".format("Metric Name", "Value"))
sortedMap.foreach {
case (metricName, value) =>
val specifier = value match {
case _ @ (_: java.lang.Float | _: java.lang.Double) => "%.3f"
case _ => "%s"
}
println(s"%-${maxLengthOfDisplayName}s : $specifier".format(metricName, value))
}
}

/**
* This is a simple wrapper around `CommandLineUtils.printUsageAndExit`.
* It is needed for tools migration (KAFKA-14525), as there is no Java equivalent for return type `Nothing`.
Expand Down
45 changes: 0 additions & 45 deletions core/src/test/scala/kafka/utils/ToolsUtilsTest.scala

This file was deleted.