From fc946a1dd1d34758eb35c7382595faaac1ab5cc1 Mon Sep 17 00:00:00 2001 From: Daniel Ching <110129035+daching-provectus@users.noreply.github.com> Date: Wed, 14 Sep 2022 19:00:46 -0600 Subject: [PATCH] Handle error message for schemas (#2520) Co-authored-by: Roman Zabaluev --- .../com/provectus/kafka/ui/service/SchemaRegistryService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 92603ba979..2a3039b3fe 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 @@ -66,6 +66,7 @@ public class SchemaRegistryService { private static final String UNRECOGNIZED_FIELD_SCHEMA_TYPE = "Unrecognized field: schemaType"; private static final String INCOMPATIBLE_WITH_AN_EARLIER_SCHEMA = "incompatible with an earlier schema"; + private static final String INVALID_SCHEMA = "Invalid Schema"; private final WebClient webClient; @@ -237,7 +238,8 @@ public class SchemaRegistryService { } else if (isIncompatibleSchemaMessage(x.getMessage())) { return Mono.error(new SchemaCompatibilityException(x.getMessage())); } else { - return Mono.error(new UnprocessableEntityException(x.getMessage())); + log.error(x.getMessage()); + return Mono.error(new UnprocessableEntityException(INVALID_SCHEMA)); } }