From 0283359d4a7e72651475ff65d79959114c587e29 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 15 Oct 2019 15:11:05 -0400 Subject: [PATCH] Add a delay before the metrics assertion --- .../function/KafkaStreamsBinderWordCountFunctionTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 9defbf2c1..d3382cdf3 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 @@ -96,8 +96,8 @@ public class KafkaStreamsBinderWordCountFunctionTests { "--spring.cloud.stream.kafka.streams.binder.brokers=" + embeddedKafka.getBrokersAsString())) { receiveAndValidate("words", "counts"); final MeterRegistry meterRegistry = context.getBean(MeterRegistry.class); - //TODO: This assertion fails randomly - Investigate why. - //assertThat(meterRegistry.get("stream.metrics.commit.total").gauge().value()).isEqualTo(1.0); + Thread.sleep(100); + assertThat(meterRegistry.get("stream.metrics.commit.total").gauge().value()).isEqualTo(1.0); } }