Rename KafkaSerde to CodecSerde, because now it has nothing in common

with Kafka.

Author: Passarinho4

Diff for: commons-kafka/src/main/scala/com/avsystem/commons/kafka/KafkaSerde.scala renamed to commons-kafka/src/main/scala/com/avsystem/commons/kafka/CodecSerde.scala

@@ -5,7 +5,7 @@ import java.io.{ByteArrayInputStream, ByteArrayOutputStream, DataInputStream, Da
 
 import com.avsystem.commons.serialization.{GenCodec, StreamInput, StreamOutput}
 
-private[kafka] class KafkaSerde[T](codec: GenCodec[T]) {
+private[kafka] class CodecSerde[T](codec: GenCodec[T]) {
 
   def deserialize(in: ByteArrayInputStream): T = {
     val input = new StreamInput(new DataInputStream(in))

Diff for: commons-kafka/src/main/scala/com/avsystem/commons/kafka/SerdeRegistry.scala

@@ -8,14 +8,14 @@ import com.avsystem.commons.serialization.GenCodec
 
 class SerdeRegistry[T](codecs: Map[Byte, GenCodec[_ <: T]]) extends AbstractDeserializer[T] {
 
-  private val registry = codecs.mapValues(new KafkaSerde(_))
+  private val registry = codecs.mapValues(new CodecSerde(_))
 
   override def deserialize(topic: String, data: Array[Byte]): T = {
     val input = new ByteArrayInputStream(data)
     val version = input.read()
     if (version != -1) {
       registry.get(version.toByte) match {
-        case Some(serde: KafkaSerde[T]) => serde.deserialize(input)
+        case Some(serde: CodecSerde[T]) => serde.deserialize(input)
         case _ => throw new UnsupportedVersionEvent(s"Unsupported version ${data.head}, add proper serde to registry.")
       }
     } else {

Diff for: commons-kafka/src/main/scala/com/avsystem/commons/kafka/VersionedSerializer.scala

@@ -7,7 +7,7 @@ import com.avsystem.commons.serialization.GenCodec
 
 class VersionedSerializer[T](version: Byte)(implicit codec: GenCodec[T]) extends AbstractSerializer[T] {
 
-  private val serde = new KafkaSerde(codec)
+  private val serde = new CodecSerde(codec)
 
   override def serialize(topic: String, data: T): Array[Byte] = {
     val output = new ByteArrayOutputStream()

Diff for: commons-kafka/src/test/scala/com/avsystem/commons/kafka/KafkaSerdeNestedTest.scala renamed to commons-kafka/src/test/scala/com/avsystem/commons/kafka/CodecSerdeNestedTest.scala

@@ -7,7 +7,7 @@ import com.avsystem.commons.serialization.GenCodec
 import org.apache.kafka.common.serialization.Serializer
 import org.scalatest.FunSuite
 
-class KafkaSerdeNestedTest extends FunSuite {
+class CodecSerdeNestedTest extends FunSuite {
 
   trait TestEvent
 

Diff for: commons-kafka/src/test/scala/com/avsystem/commons/kafka/KafkaSerdeTest.scala renamed to commons-kafka/src/test/scala/com/avsystem/commons/kafka/CodecSerdeTest.scala

@@ -8,7 +8,7 @@ import com.avsystem.commons.serialization.GenCodec
 import org.apache.kafka.common.serialization.Serializer
 import org.scalatest.FunSuite
 
-class KafkaSerdeTest extends FunSuite {
+class CodecSerdeTest extends FunSuite {
 
   sealed trait TestEvent
 
@@ -39,7 +39,7 @@ class KafkaSerdeTest extends FunSuite {
     val event = TestEvent3("Martin")
 
 
-    val testEvent3Serde = new KafkaSerde[TestEvent3](GenCodec.materialize[TestEvent3])
+    val testEvent3Serde = new CodecSerde[TestEvent3](GenCodec.materialize[TestEvent3])
     val output = new ByteArrayOutputStream()
     output.write(3)