fix(topic-data): add basic deserialization of avro primitive (#715)

close #700
tchiotludo · Jun 7, 2021 · 386a257 · 386a257
1 parent 0d3856d
commit 386a257
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/main/java/org/akhq/models/Record.java b/src/main/java/org/akhq/models/Record.java
@@ -123,7 +123,14 @@ private String convertToString(byte[] payload, Integer schemaId, boolean isKey)
             return null;
         } else if (schemaId != null) {
             try {
-                GenericRecord record = (GenericRecord) kafkaAvroDeserializer.deserialize(topic, payload);
+                Object toType = kafkaAvroDeserializer.deserialize(topic, payload);
+
+                //for primitive avro type
+                if (!(toType instanceof GenericRecord)){
+                    return String.valueOf(toType);
+                }
+
+                GenericRecord record = (GenericRecord) toType;
                 return AvroToJsonSerializer.toJson(record);
             } catch (Exception exception) {
                 this.exceptions.add(exception.getMessage());