You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Federico Giraud <gi...@gmail.com> on 2015/02/14 02:23:03 UTC

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