Fixing test

This commit is contained in:
Soby Chacko
2022-01-18 12:59:47 -05:00
parent 417665773c
commit ee888a15ba

View File

@@ -211,7 +211,7 @@ public class InteractiveQueryService {
throwable = e; throwable = e;
} }
throw new IllegalStateException( 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."));
}); });
} }