java compatibility fix (#33)

Author: davideicardi

kaa/src/main/scala/com/davideicardi/kaa/avro/AvroSingleObjectEncoding.scala

@@ -11,7 +11,7 @@ object AvroSingleObjectEncoding {
    * Note: this is not the same encoding using by Confluent Avro serializer.
    * Confluent Avro serializer uses 0x00 as magic byte and and id of 4 bytes (incremental? not an hash).
    */
-  val default : AvroSingleObjectEncoding = {
+  val AVRO_OFFICIAL : AvroSingleObjectEncoding = {
     new AvroSingleObjectEncoding(
       Array(0xC3.toByte, 0x01.toByte),
       ByteOrder.LITTLE_ENDIAN,

kaa/src/main/scala/com/davideicardi/kaa/avro/AvroSingleObjectSerializer.scala

@@ -7,7 +7,7 @@ import com.davideicardi.kaa.SchemaNotFoundException
 class AvroSingleObjectSerializer[T >: Null : SchemaFor : Encoder : Decoder]
 (
   schemaRegistry: SchemaRegistry,
-  encoding: AvroSingleObjectEncoding = AvroSingleObjectEncoding.default
+  encoding: AvroSingleObjectEncoding = AvroSingleObjectEncoding.AVRO_OFFICIAL
 ){
   private val binarySerializer = new AvroBinarySerializer[T]()
   private lazy val currentSchemaId = schemaRegistry.put(binarySerializer.currentSchema)

kaa/src/main/scala/com/davideicardi/kaa/avro/GenericAvroSingleObjectSerializer.scala

@@ -7,8 +7,11 @@ import org.apache.avro.generic.GenericRecord
 class GenericAvroSingleObjectSerializer
 (
   schemaRegistry: SchemaRegistry,
-  encoding: AvroSingleObjectEncoding = AvroSingleObjectEncoding.default
+  encoding: AvroSingleObjectEncoding,
 ){
+  def this(schemaRegistry: SchemaRegistry) = {
+    this(schemaRegistry, AvroSingleObjectEncoding.AVRO_OFFICIAL)
+  }
 
   private val binarySerializer = new GenericAvroBinarySerializer()
 
@@ -19,7 +22,10 @@ class GenericAvroSingleObjectSerializer
     encoding.encode(bytes, currentSchemaId)
   }
 
-  def deserialize(bytes: Array[Byte], readerSchema: Option[Schema] = None): GenericRecord = {
+  def deserialize(bytes: Array[Byte]): GenericRecord = {
+    deserialize(bytes, None)
+  }
+  def deserialize(bytes: Array[Byte], readerSchema: Option[Schema]): GenericRecord = {
     val (schemaId, serialized) = encoding.decode(bytes)
     val schema = schemaRegistry.get(schemaId)
       .getOrElse(throw new SchemaNotFoundException(s"Schema $schemaId not found in registry"))

kaa/src/test/scala/kaa/darwin/AvroSingleObjectSerializerSpec.scala

@@ -28,7 +28,7 @@ class AvroSingleObjectSerializerSpec extends AnyFlatSpec with should.Matchers {
   it should "serialize a class with a single object encoding" in {
     val encoded = singleObjectSerializer.serialize(dragonite)
 
-    val (schemaId, bin) = AvroSingleObjectEncoding.default.decode(encoded)
+    val (schemaId, bin) = AvroSingleObjectEncoding.AVRO_OFFICIAL.decode(encoded)
     val binarySerializer = new AvroBinarySerializer[Pokemon]
 
     schemaId should be (AvroUtils.calcFingerprint(AvroSchema[Pokemon]))

kaa/src/test/scala/kaa/darwin/GenericAvroSingleObjectSerializerSpec.scala

@@ -68,7 +68,7 @@ class GenericAvroSingleObjectSerializerSpec extends AnyFlatSpec with should.Matc
 
     val encoded = singleObjectSerializer.serialize(record)
 
-    val (schemaId, bin) = AvroSingleObjectEncoding.default.decode(encoded)
+    val (schemaId, bin) = AvroSingleObjectEncoding.AVRO_OFFICIAL.decode(encoded)
     val binarySerializer = new GenericAvroBinarySerializer
 
     schemaId should be (AvroUtils.calcFingerprint(schemaV1))

sample/src/main/scala/sampleApp.scala

@@ -25,9 +25,9 @@ object SampleApp {
             val bytesV2 = serializerV2.serialize(SuperheroV2("Spiderman", "Peter Parker"))
 
             // v1 schema
-            val (schemaIdv1, _) = AvroSingleObjectEncoding.default.decode(bytesV1)
+            val (schemaIdv1, _) = AvroSingleObjectEncoding.AVRO_OFFICIAL.decode(bytesV1)
             println(s"v1 $schemaIdv1")
-            val (schemaIdv2, _) = AvroSingleObjectEncoding.default.decode(bytesV2)
+            val (schemaIdv2, _) = AvroSingleObjectEncoding.AVRO_OFFICIAL.decode(bytesV2)
             println(s"v2 $schemaIdv2")
 
             // normal deserialization