@Override
    public Object fromBytes(byte[] bytes) {
      GenericRecord record;
      try {
        record = genericRecordFromBytes(bytes, schema);
      } catch (IOException e) {
        throw new SamzaException("Unable to deserialize the record", e);
      }
      return record;
    }
Avro SerDe that can be used to serialize or deserialize the avro {@link GenericRecord}.
samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSerDeFactory.java