Reading data from confluent schema registry without using their library

ReadData.scala

import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.common.serialization.{Deserializer, StringDeserializer}
import org.apache.kafka.common.utils.ByteUtils

/**
* Not recommended for production but useful when you want to write some kind of
* quick script that reads data off kafka.
*/
object ReadData {
  
  type MyType = ??? // some protobuf type
  
  val myTypeDeserializer: Deserializer[MyType] = { (topic, data) =>
    val bb = ByteBuffer.wrap(data)
    bb.get // magic number
    bb.getInt // version number
    val indexes = ByteUtils.readVarint(bb)
    for (_ <- Range(0, indexes)) ByteUtils.readVarint(bb)
    MyType.parseFrom(bb) // assuming Protobuf here
  }
}