[
https://issues.apache.org/jira/browse/KAFKA-2219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2219:
--------------------------------
Fix Version/s: (was: 0.8.3)
> reassign partition fails with offset 0 being asked for but obviously not there
> ------------------------------------------------------------------------------
>
> Key: KAFKA-2219
> URL: https://issues.apache.org/jira/browse/KAFKA-2219
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8.1.1
> Reporter: Joe Stein
> Priority: Critical
>
> may be related to there being no data anymore in the partition
> [2015-05-23 15:51:05,506] 122615762 [request-expiration-task] ERROR
> kafka.server.KafkaApis - [KafkaApi-10206101] Error when processing fetch
> request for partition [cs.sensor.wrapped,44] offset 0 from fo
> llower with correlation id 3
> kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have
> log segments in the range 1339916216 to 1339916216.
> at kafka.log.Log.read(Log.scala:380)
> at
> kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:530)
> at
> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:476)
> at
> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:471)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at scala.collection.immutable.Map$Map2.foreach(Map.scala:130)
> at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
> at scala.collection.AbstractTraversable.map(Traversable.scala:105)
> at
> kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:471)
> at
> kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:783)
> at
> kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:765)
> at
> kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216)
> at java.lang.Thread.run(Thread.java:722)
> This topic was stopped from having data produced to it, wait for the log
> clean up (so no data in partitions) and then reassign. it also maybe related
> to some brokers being an bad state
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
