Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2015-04-29 21:33:52,924] ERROR [KafkaApi-1] Error processing ProducerRequest with correlation id 3417 from client samza_producer-s2_call_w_deploy_to_json-1-1430357421070-4 on partition [svc.call.w_deploy.T2UDe2PWRYWcVAAAhMOAwA,7] (kafka.server.KafkaApis)
- kafka.common.KafkaException: Error in validating messages while appending to log 'svc.call.w_deploy.T2UDe2PWRYWcVAAAhMOAwA-7'
- at kafka.log.Log.liftedTree1$1(Log.scala:277)
- at kafka.log.Log.append(Log.scala:274)
- at kafka.cluster.Partition$$anonfun$appendMessagesToLeader$1.apply(Partition.scala:379)
- at kafka.cluster.Partition$$anonfun$appendMessagesToLeader$1.apply(Partition.scala:365)
- at kafka.utils.Utils$.inLock(Utils.scala:535)
- at kafka.utils.Utils$.inReadLock(Utils.scala:541)
- at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:365)
- at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:291)
- at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:282)
- at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
- at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
- at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:93)
- at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:93)
- at scala.collection.Iterator$class.foreach(Iterator.scala:660)
- at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
- at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
- at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:43)
- at scala.collection.mutable.HashMap.foreach(HashMap.scala:93)
- at scala.collection.TraversableLike$class.map(TraversableLike.scala:194)
- at scala.collection.mutable.HashMap.map(HashMap.scala:43)
- at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:282)
- at kafka.server.KafkaApis.handleProducerOrOffsetCommitRequest(KafkaApis.scala:204)
- at kafka.server.KafkaApis.handle(KafkaApis.scala:59)
- at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:59)
- at java.lang.Thread.run(Thread.java:745)
- Caused by: java.io.IOException: PARSING_ERROR(2)
- at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:84)
- at org.xerial.snappy.SnappyNative.uncompressedLength(Native Method)
- at org.xerial.snappy.Snappy.uncompressedLength(Snappy.java:594)
- at org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:358)
- at org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:167)
- at org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:150)
- at java.io.InputStream.read(InputStream.java:101)
- at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:67)
- at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:67)
- at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:67)
- at scala.collection.immutable.Stream$.continually(Stream.scala:679)
- at scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:679)
- at scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:679)
- at scala.collection.immutable.Stream$Cons.tail(Stream.scala:634)
- at scala.collection.immutable.Stream$Cons.tail(Stream.scala:626)
- at scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:440)
- at scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:440)
- at scala.collection.immutable.Stream$Cons.tail(Stream.scala:634)
- at scala.collection.immutable.Stream$Cons.tail(Stream.scala:626)
- at scala.collection.immutable.Stream.foreach(Stream.scala:292)
- at kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:67)
- at kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:179)
- at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:192)
- at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:146)
- at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
- at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
- at scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:334)
- at scala.collection.Iterator$class.foreach(Iterator.scala:660)
- at scala.collection.Iterator$$anon$19.foreach(Iterator.scala:333)
- at scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48)
- at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:99)
- at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250)
- at scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:333)
- at kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:220)
- at kafka.log.Log.liftedTree1$1(Log.scala:275)
- ... 24 more
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement