Fixing avro deserialization
Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/be32e18b Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/be32e18b Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/be32e18b Branch: refs/heads/master Commit: be32e18b30e2243aa188945de22d936094cc29f0 Parents: a901018 Author: Jakub Jankowski <[email protected]> Authored: Wed May 10 14:45:16 2017 +0200 Committer: nkourtellis <[email protected]> Committed: Fri Jul 21 21:12:18 2017 +0300 ---------------------------------------------------------------------- .../main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/be32e18b/samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java ---------------------------------------------------------------------- diff --git a/samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java b/samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java index 42d11bc..afbc002 100644 --- a/samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java +++ b/samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaAvroMapper.java @@ -21,7 +21,6 @@ import java.io.File; import java.io.IOException; import org.apache.avro.Schema; -import org.apache.avro.generic.GenericDatumReader; import org.apache.avro.generic.GenericDatumWriter; import org.apache.avro.io.BinaryEncoder; import org.apache.avro.io.DatumReader; @@ -126,7 +125,7 @@ public class KafkaAvroMapper implements KafkaDeserializer<InstanceContentEvent>, try { Schema schema = new Schema.Parser().parse(new File("C:/java/avro/kafka.avsc")); ByteArrayInputStream in = new ByteArrayInputStream(avroBytes); - DatumReader<V> reader = new GenericDatumReader<>(schema); + DatumReader<V> reader = new ReflectDatumReader<>(schema); Decoder decoder = DecoderFactory.get().directBinaryDecoder(in, null);
