From ee888a15bab5d1b443d126f0fbadd25f4c6f26c9 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 18 Jan 2022 12:59:47 -0500 Subject: [PATCH] Fixing test --- .../stream/binder/kafka/streams/InteractiveQueryService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java index 33e7890c3..d8f350af6 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/InteractiveQueryService.java @@ -211,7 +211,7 @@ public class InteractiveQueryService { throwable = e; } throw new IllegalStateException( - "Error when retrieving state store", throwable != null ? throwable : new Throwable("Kafka Streams is not ready.")); + "Error when retrieving state store.", throwable != null ? throwable : new Throwable("Kafka Streams is not ready.")); }); }