[ https://issues.apache.org/jira/browse/KAFKA-530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jay Kreps resolved KAFKA-530. ----------------------------- Resolution: Won't Fix > kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException > -------------------------------------------------------------- > > Key: KAFKA-530 > URL: https://issues.apache.org/jira/browse/KAFKA-530 > Project: Kafka > Issue Type: Bug > Reporter: John Fung > Labels: replication-testing > Attachments: system_test_1348521165.tar.gz > > > 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) -- This message was sent by Atlassian JIRA (v6.3.4#6332)