Sample serialization function for the Kafka2Avro pipelines

serialize.scala

  /** Returns a string representation of an object.
    *
    * Overwrite this function with your serialization code. In this example, we
    * serialize the object and transform that into a base64 encoded string,
    * which will be later on written to Kafka.
    *
    * @tparam T The type of the object ot be serialized. The type must be Serializable
    * @param obj The object to be serialized
    */
  def object2String[T](obj: T): String = {
    val bos = new ByteArrayOutputStream()
    val oos = new ObjectOutputStream(bos)
    oos.writeObject(obj)
    oos.close()

    val s: String = Base64.getEncoder.encodeToString(bos.toByteArray)

    s
  }