Hi,

I'm using kafka-consumer-perf-test but I'm getting an error if I add the 
--print-metrics option.

Here's a snippet of my output including the error:

consumer-fetch-manager-metrics:fetch-size-max:{client-id=consumer-perf-consumer-99250-1}
                                                  : 0.000
consumer-fetch-manager-metrics:fetch-throttle-time-avg:{client-id=consumer-perf-consumer-99250-1}
                                         : 0.000
consumer-fetch-manager-metrics:fetch-throttle-time-max:{client-id=consumer-perf-consumer-99250-1}
                                         : 0.000
consumer-fetch-manager-metrics:fetch-total:{client-id=consumer-perf-consumer-99250-1}
                                                     : 72.000
Exception in thread "main" java.util.IllegalFormatConversionException: f != 
java.lang.Integer
        at 
java.util.Formatter$FormatSpecifier.failConversion(Formatter.java:4302)
        at java.util.Formatter$FormatSpecifier.printFloat(Formatter.java:2806)
        at java.util.Formatter$FormatSpecifier.print(Formatter.java:2753)
        at java.util.Formatter.format(Formatter.java:2520)
        at java.util.Formatter.format(Formatter.java:2455)
        at java.lang.String.format(String.java:2940)
        at scala.collection.immutable.StringLike.format(StringLike.scala:354)
        at scala.collection.immutable.StringLike.format$(StringLike.scala:353)
        at scala.collection.immutable.StringOps.format(StringOps.scala:33)
        at kafka.utils.ToolsUtils$.$anonfun$printMetrics$3(ToolsUtils.scala:60)
        at 
kafka.utils.ToolsUtils$.$anonfun$printMetrics$3$adapted(ToolsUtils.scala:58)
        at 
scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
        at 
scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
        at kafka.utils.ToolsUtils$.printMetrics(ToolsUtils.scala:58)
        at kafka.tools.ConsumerPerformance$.main(ConsumerPerformance.scala:82)
        at kafka.tools.ConsumerPerformance.main(ConsumerPerformance.scala)

Does anyone have the same issue? Am I doing something wrong?

Regards,

JP Silva

Reply via email to