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