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

Reply via email to