kafka.common.KafkaException: Should not set log end offset on partition [waflogtopic,1]'s local replica 787

GitHub | mattshma | 2 weeks ago
  1. 0

    Should not set log end offset on partition

    GitHub | 2 weeks ago | mattshma
    kafka.common.KafkaException: Should not set log end offset on partition [waflogtopic,1]'s local replica 787
  2. 0

    kafka.common.UnknownException after topic creation

    GitHub | 1 year ago | brucardoso2
    kafka.common.KafkaException: Should not set log end offset on partition [omg_3,2]'s local replica 17975
  3. 0

    kafka issue

    kafka-users | 10 months ago | Mudit Agarwal
    java.lang.IllegalStateException: Failed to read complete buffer for targetOffset 586475 startPosition 824825447 in /kafka/kafka-logs/<topic name>/00000000000000494997.log
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    kafka issue

    kafka-users | 10 months ago | Mudit Agarwal
    java.lang.IllegalStateException: Failed to read complete buffer for targetOffset 586475 startPosition 824825447 in /kafka/kafka-logs/<topic name>/00000000000000494997.log

    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. kafka.common.KafkaException

      Should not set log end offset on partition [waflogtopic,1]'s local replica 787

      at kafka.cluster.Replica.logEndOffset_$eq()
    2. Apache Kafka
      ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply
      1. kafka.cluster.Replica.logEndOffset_$eq(Replica.scala:66)
      2. kafka.cluster.Replica.updateLogReadResult(Replica.scala:53)
      3. kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:241)
      4. kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:861)
      5. kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:858)
      5 frames
    3. Scala
      HashMap$HashTrieMap.foreach
      1. scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221)
      2. scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428)
      2 frames
    4. Apache Kafka
      KafkaRequestHandler.run
      1. kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:858)
      2. kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:472)
      3. kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:467)
      4. kafka.server.KafkaApis.handle(KafkaApis.scala:77)
      5. kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
      5 frames
    5. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame