Schema schema = .... @SuppressWarnings("static-access")
Decoder binaryDecoder = DecoderFactory.get().get().binaryDecoder(value.toString().getBytes(), null);
System.out.println("test");
@SuppressWarnings("rawtypes")
GenericDatumReader<GenericRecord> payloadReader = new SpecificDatumReader<GenericRecord>(schema);
System.out.println("test1" + binaryDecoder.toString().length()+ "test");
GenericRecord recode = null;
recode = payloadReader.read(recode, binaryDecoder);
System.out.println("test2");
... View more
