Skip to content

Instantly share code, notes, and snippets.

@ezsi

ezsi/ProtoBufEncoder.scala

Created May 9, 2015 13:27
Show Gist options
  • Save ezsi/153ff1b661198e21e7d9 to your computer and use it in GitHub Desktop.
Save ezsi/153ff1b661198e21e7d9 to your computer and use it in GitHub Desktop.
Download ZIP
ProtoBuf encoder for Kafka
Raw
ProtoBufEncoder.scala
class ProtoBufEncoder(props: VerifiableProperties = null) extends Encoder[com.google.protobuf.GeneratedMessage] {
override def toBytes(protoBufMessage: com.google.protobuf.GeneratedMessage): Array[Byte] = protoBufMessage.toByteArray
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment