Serializing.java

// the gist of my deserialize
private DatumReader<GenericRecord> reader;
reader = new SpecificDatumReader<>(writerSchema, readerSchema);

GenericRecord deserialize(byte[] msg) throws IOException, IllegalStateException
{
  BinaryDecoder decoder = DecoderFactory.get().binaryDecoder(msg, null);
  return reader.read(null, decoder);
}