Skip to content

Commit 386a257

Browse files
authoredJun 7, 2021
fix(topic-data): add basic deserialization of avro primitive (tchiotludo#715)
close tchiotludo#700
1 parent 0d3856d commit 386a257

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed
 

‎src/main/java/org/akhq/models/Record.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,14 @@ private String convertToString(byte[] payload, Integer schemaId, boolean isKey)
123123
return null;
124124
} else if (schemaId != null) {
125125
try {
126-
GenericRecord record = (GenericRecord) kafkaAvroDeserializer.deserialize(topic, payload);
126+
Object toType = kafkaAvroDeserializer.deserialize(topic, payload);
127+
128+
//for primitive avro type
129+
if (!(toType instanceof GenericRecord)){
130+
return String.valueOf(toType);
131+
}
132+
133+
GenericRecord record = (GenericRecord) toType;
127134
return AvroToJsonSerializer.toJson(record);
128135
} catch (Exception exception) {
129136
this.exceptions.add(exception.getMessage());

0 commit comments

Comments
 (0)