Hello, I recently upgraded a java producer from the 0.8.2-beta client library to the 0.8.2. The producer is writing to a 0.8.1.1 kafka cluster. It was running without issues with the 0.8.2-beta version, but when i switched to the new one i get snappy exceptions on kafka logs.
Logs: http://paste.ubuntu.com/10213104/ If i start the producer on a running cluster everything looks fine, but as soon as i restart a broker or force a leader election i start seeing a lot of those errors on multiple brokers. I tried different snappy and libsnappy-java versions but i had no success so far. Thanks, Federico