Kafka
  1. Kafka
  2. KAFKA-530

kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Won't Fix
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None

      Description

      1. Attached file system_test_1348521165.tar.gz contains all the associated log files for this test session.

      2. The system test output log can be found at: system_test_1348521165/system_test_output.log

      3. The following log message can be found at: system_test_1348521165/logs/broker-2/kafka_server_9092.log

      [2012-09-24 14:15:29,020] INFO Conditional update the zkPath /brokers/topics/test_1/partitions/0/leaderAndISR with expected version 161 succeed and return the new version: 162 (kafka.utils.ZkUtils$)
      [2012-09-24 14:15:29,533] ERROR [KafkaApi-2] error when processing request (test_1,0,15618,1048576) (kafka.server.KafkaApis)
      kafka.common.OffsetOutOfRangeException: offset 15618 is out of range
      at kafka.log.Log$.findRange(Log.scala:48)
      at kafka.log.Log.read(Log.scala:294)
      at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:336)
      at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:296)
      at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:293)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
      at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
      at scala.collection.immutable.Map$Map1.map(Map.scala:93)
      at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:293)
      at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:464)
      at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:450)
      at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:213)
      at java.lang.Thread.run(Thread.java:662)

        Activity

        Hide
        Neha Narkhede added a comment -

        John, do you still see this issue on the latest 0.8 branch ?

        Show
        Neha Narkhede added a comment - John, do you still see this issue on the latest 0.8 branch ?

          People

          • Assignee:
            Unassigned
            Reporter:
            John Fung
          • Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development