High delay during controlled shutdown and acks=-1

Hi, I have few java async producers sending data to a 4-node Kafka cluster version 0.8.2, containing few thousand topics, all with replication factor 2. When i use acks=1 and trigger a controlled shutdown + restart on one broker, the producers will send data to the new leader, reporting a very low

Snappy fails to uncompress with new producer

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.u