Hi Jordan, I ran into a similiar issue when using snappy compression and the new producer. If you disable compression or switch to lz4 or gzip, does the issue go away?
Cheers, Roger On Wed, Jul 22, 2015 at 11:54 PM, Jordan Shaw <jor...@pubnub.com> wrote: > Hey Everyone, > I'm getting an: > "kafka.message.InvalidMessageException: Message found with corrupt size > (0)" > > in my kafka server.log here is the full stack trace: > https://gist.github.com/jshaw86/516cf47b6fd7559e7dc1. > > It indicates that the error is caused by a bad produce call from the samza > producer any idea what could be causing this? Just about the only thing > that I can find is maybe a issue with snappy or compression but I don't see > a snappy call in the traceback. > > -- > Jordan Shaw > Full Stack Software Engineer > PubNub Inc >
