diff --git a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/AvroJsonConverter.java b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/AvroJsonConverter.java index c7a092e528..f58642c552 100755 --- a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/AvroJsonConverter.java +++ b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/AvroJsonConverter.java @@ -115,7 +115,7 @@ public String endcodeToJson(T record) throws IOException{ */ public byte[] encodeToJsonBytes(T record) throws IOException{ ByteArrayOutputStream baos = new ByteArrayOutputStream(); - jsonEncoder = EncoderFactory.get().jsonEncoder(this.schema, baos, false, true); + jsonEncoder = EncoderFactory.get().jsonEncoder(this.schema, baos, true); avroWriter.write(record, jsonEncoder); jsonEncoder.flush(); baos.flush(); diff --git a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/GenericAvroConverter.java b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/GenericAvroConverter.java index 1d98147f45..650a773386 100644 --- a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/GenericAvroConverter.java +++ b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/avro/GenericAvroConverter.java @@ -156,7 +156,7 @@ public String encodeToJson(T record) throws IOException{ */ public byte[] encodeToJsonBytes(T record) throws IOException{ ByteArrayOutputStream baos = new ByteArrayOutputStream(); - jsonEncoder = EncoderFactory.get().jsonEncoder(this.schema, baos, false, true); + jsonEncoder = EncoderFactory.get().jsonEncoder(this.schema, baos, true); datumWriter.write(record, jsonEncoder); jsonEncoder.flush(); baos.flush(); diff --git a/pom.xml b/pom.xml index 929819d7ac..89ec1d919b 100644 --- a/pom.xml +++ b/pom.xml @@ -54,8 +54,8 @@ Copyright 2014-2016 CyberVision, Inc. 1.5.0.1 4.0.34.Final - 1.8.1-KAA - 1.8.1 + 1.7.5-KAA + 1.7.5 1.7 3.4.6 2.9.0 @@ -458,7 +458,7 @@ Copyright 2014-2016 CyberVision, Inc. avro-maven-plugin - [1.7.5,) + [1.7.5-KAA,) schema @@ -951,7 +951,7 @@ Copyright 2014-2016 CyberVision, Inc. org.apache.avro avro-compiler - ${avro.version} + ${avro-kaa.version} org.apache.avro @@ -961,7 +961,7 @@ Copyright 2014-2016 CyberVision, Inc. org.apache.avro avro-mapred - ${avro.version} + ${avro-kaa.version} org.apache.velocity