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

GitHub | mattshma | 3 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Should not set log end offset on partition

    GitHub | 3 months 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设计解析:Replication工具 – 过往记忆

    iteblog.com | 1 week ago
    kafka.common.NotAssignedReplicaException: Leader 3 failed to record follower 0's position 0 for partition [test,3] since the replica 0 is not recognized to be one of the assigned replicas 2,3 for partition [test,3]
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    kafka issue

    kafka-users | 12 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
  6. 0

    kafka issue

    kafka-users | 12 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