kafka.common.KafkaException

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

Samebug tips0

There are no available Samebug tips for this exception. If you know how to solve this issue, help other users by writing a short tip.

Don't give up yet. Paste your full stack trace to get a solution.

Solutions on the web109

  • Should not set log end offset on partition [waflogtopic,1]'s local replica 787
  • Should not set log end offset on partition [omg_3,2]'s local replica 17975
  • Trying to roll a new log segment for topic partition NusWriteEvent-4 with start offset 0 while it already exsits
  • Stack trace

    • kafka.common.KafkaException: Should not set log end offset on partition [waflogtopic,1]'s local replica 787 at kafka.cluster.Replica.logEndOffset_$eq(Replica.scala:66) at kafka.cluster.Replica.updateLogReadResult(Replica.scala:53) at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:241) at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:861) at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:858) at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221) at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428) at kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:858) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:472) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:467) at kafka.server.KafkaApis.handle(KafkaApis.scala:77) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) at java.lang.Thread.run(Thread.java:745)

    Write tip

    You have a different solution? A short tip here would help you and many other users who saw this issue last week.

    Users with the same issue

    Unknown user
    Once, 1 year ago