Hi Kafka Users,
I have written my own implementation of the kafka Encoder class for
serializing objects to Messages. It uses Kryo, which is a non-thread safe
java serialization library. I'm using Kafka 0.7.2.
We recently ran into an issue where we increased the number of kafka
brokers for our kafk
nce in that case you will have concurrent access.
>
> Guozhang
>
>
> On Mon, Jan 12, 2015 at 5:32 PM, Elizabeth Bennett
> wrote:
>
> > Hi Kafka Users,
> > I have written my own implementation of the kafka Encoder class for
> > serializing objects to Messages.
t be some calling pattern corner cases that cause
> concurrent access of the serializer.
>
> Also, I would recommend you to try out the new version of Kafka (0.8.x), in
> which each producer will only have one back ground thread for sending data,
> guaranteeing thread safety.
>
&g
