Browse Source

minor fix

iliax 1 year ago
parent
commit
c6ec8827dd

+ 1 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/sr/Serialize.java

@@ -81,7 +81,7 @@ class Serialize {
     DynamicMessage.Builder builder = schema.newMessageBuilder();
     DynamicMessage.Builder builder = schema.newMessageBuilder();
     JsonFormat.parser().merge(input, builder);
     JsonFormat.parser().merge(input, builder);
     Message message = builder.build();
     Message message = builder.build();
-    MessageIndexes indexes = schema.toMessageIndexes(message.getDescriptorForType().getFullName(), false);
+    MessageIndexes indexes = schema.toMessageIndexes(message.getDescriptorForType().getFullName(), normalizeSchema);
     try (var out = new ByteArrayOutputStream()) {
     try (var out = new ByteArrayOutputStream()) {
       out.write(MAGIC);
       out.write(MAGIC);
       out.write(schemaId(schemaId));
       out.write(schemaId(schemaId));