Merge branch 'snapshots'

[aquarium] / src / main / scala / gr / grnet / aquarium / message / avro / AvroHelpers.scala

diff --git a/src/main/scala/gr/grnet/aquarium/message/avro/AvroHelpers.scala b/src/main/scala/gr/grnet/aquarium/message/avro/AvroHelpers.scala
index 62ee382..2335bb2 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/message/avro/AvroHelpers.scala
+++ b/src/main/scala/gr/grnet/aquarium/message/avro/AvroHelpers.scala
@@ -94,7 +94,7 @@ object AvroHelpers {
   def bytesOfSpecificRecord[R <: SpecificRecord](r: R): Array[Byte] = {
     val schema = r.getSchema
     val out = new ByteArrayOutputStream()
-    val encoder = EncoderFactory.get().binaryEncoder(out, null)
+    val encoder = DefaultEncoderFactory.binaryEncoder(out, null)
     val writer = new SpecificDatumWriter[R](schema)
 
     writer.write(r, encoder)