Fix performance test issues

[dcaegen2/collectors/hv-ves.git] / sources / hv-collector-kafka-consumer / src / main / kotlin / org / onap / dcae / collectors / veshv / kafkaconsumer / metrics / MicrometerMetrics.kt

diff --git a/sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/MicrometerMetrics.kt b/sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/MicrometerMetrics.kt
index 906fce2..64dbdf4 100644 (file)
--- a/sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/MicrometerMetrics.kt
+++ b/sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/MicrometerMetrics.kt
@@ -42,6 +42,7 @@ internal class MicrometerMetrics constructor(
     }.memoize<String, AtomicLong>()
 
     private val travelTime = Timer.builder(name(TRAVEL,TIME))
+            .maximumExpectedValue(MAX_BUCKET_DURATION)
             .publishPercentileHistogram(true)
             .register(registry)
 
@@ -65,6 +66,7 @@ internal class MicrometerMetrics constructor(
         private const val TRAVEL = "travel"
         private const val TIME = "time"
         private const val PREFIX = "hv-kafka-consumer"
+        internal val MAX_BUCKET_DURATION = Duration.ofSeconds(300L)
         private fun name(vararg name: String) = "$PREFIX.${name.joinToString(".")}"
     }
 }