Re: Thread safety of Encoder implementations

AM, Elizabeth Bennett ebenn...@loggly.com wrote: Hi Guozhang, Thanks for you response. We've only got one producer client (per Kryo instance) but the producer client is configured (via the broker.list config) to produce to two Kafka brokers. When we create the Producer, we pass

Re: Thread safety of Encoder implementations

in that case you will have concurrent access. Guozhang On Mon, Jan 12, 2015 at 5:32 PM, Elizabeth Bennett ebenn...@loggly.com wrote: 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

Thread safety of Encoder implementations

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