Added CompressingSerde

centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/io/Serde.kt

@@ -1,9 +1,27 @@
 package com.sksamuel.centurion.avro.io
 
+import org.apache.avro.file.Codec
+import java.nio.ByteBuffer
+
 /**
  * A [Serde] provides an easy way to convert between a data class [T] and avro encoded bytes.
  */
 interface Serde<T : Any> {
    fun serialize(obj: T): ByteArray
    fun deserialize(bytes: ByteArray): T
 }
+
+class CompressingSerde<T : Any>(private val codec: Codec, private val serde: Serde<T>) : Serde<T> {
+
+   override fun serialize(obj: T): ByteArray {
+      val bytes = serde.serialize(obj)
+      val compressed = codec.compress(ByteBuffer.wrap(bytes))
+      val b = ByteArray(compressed.remaining())
+      compressed.get(b)
+      return b
+   }
+
+   override fun deserialize(bytes: ByteArray): T {
+      return serde.deserialize(codec.decompress(ByteBuffer.wrap(bytes)).array())
+   }
+}