diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java index 4b67335a5a..ccd8dd47ad 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java @@ -365,7 +365,7 @@ public class ClusterUtil { .map(Config::entries) .flatMap(Collection::stream) .filter(entry -> entry.name().contains(CLUSTER_VERSION_PARAM_KEY)) - .findFirst().orElseThrow().value(); + .findFirst().map(ConfigEntry::value).orElse("1.0-UNKNOWN"); }