java.lang.IllegalStateException: Compressed message has magic value 0 but inner message has magic value 1

GitHub | niels-s | 2 months ago
  1. 0

    Can't produce compressed messages with timestamp

    GitHub | 2 months ago | niels-s
    java.lang.IllegalStateException: Compressed message has magic value 0 but inner message has magic value 1
  2. 0

    [Kafka-users] High Level Consumer Iterator IllegalStateException Issue - Grokbase

    grokbase.com | 8 months ago
    java.lang.IllegalStateException: Iterator is in failed state
  3. 0

    Iterator is in failed state -kafka 0.8x

    Stack Overflow | 8 months ago | Ratha
    java.lang.IllegalStateException: Iterator is in failed state 15:29:38,938 INFO [stdout] (pool-7-thread-1) listens....
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    kafka.common.MessageSizeTooLargeException

    GitHub | 3 months ago | Tracy6465
    java.lang.IllegalStateException: Iterator is in failed state
  6. 0

    GitHub comment 750#251392693

    GitHub | 2 months ago | AlbinOS
    java.lang.IllegalStateException: Compressed message has magic value 0 but inner message has magic value 1

    1 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Compressed message has magic value 0 but inner message has magic value 1

      at kafka.message.ByteBufferMessageSet$$anon$1.readMessageFromStream()
    2. Apache Kafka
      IteratorTemplate.hasNext
      1. kafka.message.ByteBufferMessageSet$$anon$1.readMessageFromStream(ByteBufferMessageSet.scala:143)
      2. kafka.message.ByteBufferMessageSet$$anon$1.liftedTree2$1(ByteBufferMessageSet.scala:111)
      3. kafka.message.ByteBufferMessageSet$$anon$1.<init>(ByteBufferMessageSet.scala:109)
      4. kafka.message.ByteBufferMessageSet$.deepIterator(ByteBufferMessageSet.scala:85)
      5. kafka.message.ByteBufferMessageSet$$anon$2.makeNextOuter(ByteBufferMessageSet.scala:367)
      6. kafka.message.ByteBufferMessageSet$$anon$2.makeNext(ByteBufferMessageSet.scala:380)
      7. kafka.message.ByteBufferMessageSet$$anon$2.makeNext(ByteBufferMessageSet.scala:335)
      8. kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:64)
      9. kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:56)
      9 frames
    3. Scala
      Iterator$class.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:893)
      1 frame
    4. Apache Kafka
      ReplicaManager$$anonfun$appendToLocalLog$2.apply
      1. kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:30)
      2. kafka.message.ByteBufferMessageSet.validateMessagesAndAssignOffsets(ByteBufferMessageSet.scala:438)
      3. kafka.log.Log.liftedTree1$1(Log.scala:339)
      4. kafka.log.Log.append(Log.scala:338)
      5. kafka.cluster.Partition$$anonfun$11.apply(Partition.scala:441)
      6. kafka.cluster.Partition$$anonfun$11.apply(Partition.scala:427)
      7. kafka.utils.CoreUtils$.inLock(CoreUtils.scala:231)
      8. kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:237)
      9. kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:427)
      10. kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:409)
      11. kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:395)
      11 frames
    5. Scala
      AbstractTraversable.map
      1. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      2. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      3. scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
      4. scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
      5. scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:230)
      6. scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
      7. scala.collection.mutable.HashMap.foreach(HashMap.scala:99)
      8. scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
      9. scala.collection.AbstractTraversable.map(Traversable.scala:104)
      9 frames
    6. Apache Kafka
      KafkaRequestHandler.run
      1. kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:395)
      2. kafka.server.ReplicaManager.appendMessages(ReplicaManager.scala:331)
      3. kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:405)
      4. kafka.server.KafkaApis.handle(KafkaApis.scala:76)
      5. kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
      5 frames
    7. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame