Skip to content

Instantly share code, notes, and snippets.

@jaceklaskowski

jaceklaskowski/person.md

Last active January 8, 2019 19:37
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save jaceklaskowski/009486b04eca3b838e6f4347e9d49fd6 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save jaceklaskowski/009486b04eca3b838e6f4347e9d49fd6 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. jaceklaskowski created this gist Jan 8, 2019.
    33 changes: 33 additions & 0 deletions person.md
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,33 @@
    ```
    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
    }
    ```