You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/10/11 06:43:02 UTC
[jira] [Commented] (KAFKA-530) kafka.server.KafkaApis:
kafka.common.OffsetOutOfRangeException
[ https://issues.apache.org/jira/browse/KAFKA-530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13473834#comment-13473834 ]
Neha Narkhede commented on KAFKA-530:
-------------------------------------
John, do you still see this issue on the latest 0.8 branch ?
> 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 is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira