Sample deserialization function for the Kafka2Avro pipelines

deserialize.scala

  /** Returns an object of type T from a base64 encoded string.
    *
    * Overwrite this function for your deserialization code. In this example, we
    * assume that Kafka contains plain old Java objects, encoded as base64
    * strings.
    *
    * @tparam T The type of the object to be recovered
    * @param s String with a base64 encoded serialized object
    */
  def string2Object[T](s: String): T = {
    val data: Array[Byte] = Base64.getDecoder.decode(s)
    val ois: ObjectInputStream = new ObjectInputStream(new ByteArrayInputStream(data))
    val result: T = ois.readObject.asInstanceOf[T]
    ois.close()

    result
  }