kafka.message.Message has a constructor that takes in a byte array. MessagePack.write takes in an Object and returns a byte array. You just need to glue the two together in a kafka.serializer.Encoder implementation.
Cheers, David On Oct 29, 2012, at 8:05 AM, Hussein Baghdadi wrote: > > Hi, > I'm using MessagePack for my objects hierarchy. > How to feed a MessagePack object to a Kafka topic? > Thanks for help and time.
