diff --git a/data-prepper-plugins/avro-codecs/src/main/java/org/opensearch/dataprepper/plugins/codec/avro/AvroInputCodec.java b/data-prepper-plugins/avro-codecs/src/main/java/org/opensearch/dataprepper/plugins/codec/avro/AvroInputCodec.java index a8fc61e2fc..cb03946585 100644 --- a/data-prepper-plugins/avro-codecs/src/main/java/org/opensearch/dataprepper/plugins/codec/avro/AvroInputCodec.java +++ b/data-prepper-plugins/avro-codecs/src/main/java/org/opensearch/dataprepper/plugins/codec/avro/AvroInputCodec.java @@ -103,6 +103,10 @@ else if(value instanceof Utf8){ value = new String(utf8Bytes, "UTF-8"); } + else if(value instanceof GenericData.Fixed){ + value = ((GenericData.Fixed) value).bytes(); + } + eventData.put(field.name(), value); } return eventData;