Re: Message corruption with new Java client + snappy + broker restart

2015-08-14 Thread Lance Laursen
I am also seeing this issue when using the new producer and snappy compression, running mirrormaker (trunk, aug 10 or so). I'm using snappy 1.1.1.7 [2015-08-14 14:15:27,876] WARN Got error produce response with correlation id 5151552 on topic-partition mytopic-56, retrying (2147480801 attempts lef

Re: Message corruption with new Java client + snappy + broker restart

2015-05-12 Thread Roger Hoover
Oops. I originally sent this to the dev list but meant to send it here. Hi, > > When using Samza 0.9.0 which uses the new Java producer client and snappy > enabled, I see messages getting corrupted on the client side. It never > happens with the old producer and it never happens with lz4, gzip,