You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Hussein Baghdadi <hu...@hotmail.com> on 2012/10/29 13:05:48 UTC

How to feed MessagePack object to Kafka?

Hi,
I'm using MessagePack for my objects hierarchy.
How to feed a MessagePack object to a Kafka topic?
Thanks for help and time.

Re: How to feed MessagePack object to Kafka?

Posted by David Arthur <mu...@gmail.com>.

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.