diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java index 899c595e9..a5f927d0d 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderMetrics.java @@ -89,7 +89,7 @@ public class KafkaStreamsBinderMetrics { ToDoubleFunction toDoubleFunction(Metric metric) { return (o) -> { if (metric.metricValue() instanceof Number) { - return (Double) metric.metricValue(); + return ((Number) metric.metricValue()).doubleValue(); } else { return 0.0; diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java index da4950926..cf26e3b4a 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java +++ b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBinderWordCountFunctionTests.java @@ -106,6 +106,7 @@ public class KafkaStreamsBinderWordCountFunctionTests { final MeterRegistry meterRegistry = context.getBean(MeterRegistry.class); Thread.sleep(100); assertThat(meterRegistry.get("stream.metrics.commit.total").gauge().value()).isEqualTo(1.0); + assertThat(meterRegistry.get("app.info.start.time.ms").gauge().value()).isNotNaN(); Assert.isTrue(LATCH.await(5, TimeUnit.SECONDS), "Failed to call customizers"); } }