PersonSerde

person.md

  case class Person(id: Long, name: String)

  class PersonSerializer extends Serializer[Person] {
    override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}

    override def serialize(topic: String, data: Person): Array[Byte] = {
      println(s">>> serialize($topic, $data)")
      s"${data.id},${data.name}".map(_.toByte).toArray
    }

    override def close(): Unit = {}
  }
  class PersonDeserializer extends Deserializer[Person] {
    override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}

    override def deserialize(topic: String, data: Array[Byte]): Person = {
      val values = new String(data).split(",")
      Person(values(0).toLong, values(1))
    }

    override def close(): Unit = {}
  }
  implicit val p: Serde[Person] = new Serde[Person] {
    override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}

    override def close(): Unit = {}

    override def serializer(): Serializer[Person] = new PersonSerializer

    override def deserializer(): Deserializer[Person] = new PersonDeserializer
  }