gistfile1.txt

class SampleMessageSerializer extends Serializer[Message] {
  private val gson: Gson = new Gson()

  override def configure(configs: java.util.Map[String, _], isKey: Boolean): Unit = {
    // nothing to do
  }

  override def serialize(topic: String, data: Message): Array[Byte] = {
 gson.toJson(data).getBytes
  }

  override def close(): Unit = {
    //nothing to do
  }
}