diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/SchemaRegistryService.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/SchemaRegistryService.java index f8eee0ca9d..3f05ddb186 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/SchemaRegistryService.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/SchemaRegistryService.java @@ -80,7 +80,7 @@ public class SchemaRegistryService { .uri(cluster.getSchemaRegistry() + URL_SUBJECT_VERSIONS, schemaName) .retrieve() .onStatus(NOT_FOUND::equals, - throwIfNotFoundStatus(formatted(NO_SUCH_SCHEMA)) + throwIfNotFoundStatus(formatted(NO_SUCH_SCHEMA, schemaName)) ).bodyToFlux(Integer.class) ).orElse(Flux.error(ClusterNotFoundException::new)); }