Member since
12-09-2015
1
Post
0
Kudos Received
0
Solutions
05-13-2016
04:14 PM
Hi, Did you see any issues with Kafka failing to read Snappy compressed messages? I'm seeing lots of this since the upgrade.. ERROR [Replica Manager on Broker 1001]: Error processing append operation on partition [testTopic,1] (kafka.server.ReplicaManager)
kafka.common.KafkaException:
at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:94)
at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:64)
at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) ... Caused by: java.io.IOException: failed to read chunk
at org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:416)
at org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:182)
at org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:163)
at java.io.DataInputStream.readFully(DataInputStream.java:195)
at java.io.DataInputStream.readLong(DataInputStream.java:416)
at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:72)
... View more