[2013-11-24 21:00:30,010] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:02:53,288] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:02:55,180] INFO Closing socket connection to /10.65.127.89. (kafka.network.Processor) [2013-11-24 21:04:11,123] INFO Closing socket connection to /10.65.127.90. (kafka.network.Processor) [2013-11-24 21:05:16,258] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:06:16,784] INFO Closing socket connection to /10.65.127.91. (kafka.network.Processor) [2013-11-24 21:06:16,785] INFO Closing socket connection to /10.65.127.91. (kafka.network.Processor) [2013-11-24 21:07:41,797] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:07:52,364] INFO Closing socket connection to /10.65.127.89. (kafka.network.Processor) [2013-11-24 21:07:52,365] INFO Closing socket connection to /10.65.127.89. (kafka.network.Processor) [2013-11-24 21:10:10,689] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:12:35,137] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:12:55,238] INFO Closing socket connection to /10.65.127.89. (kafka.network.Processor) [2013-11-24 21:12:55,238] INFO Closing socket connection to /10.65.127.89. (kafka.network.Processor) [2013-11-24 21:14:05,511] INFO Closing socket connection to /10.65.127.90. (kafka.network.Processor) [2013-11-24 21:14:11,787] INFO Closing socket connection to /10.65.127.90. (kafka.network.Processor) [2013-11-24 21:14:11,788] INFO Closing socket connection to /10.65.127.90. (kafka.network.Processor) [2013-11-24 21:14:26,322] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 0 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613234. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:26,490] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 0 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613235. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:26,528] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 1 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613235. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:26,737] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 1 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613236. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:26,744] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 2 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613236. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,245] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 2 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613236. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,251] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 3 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613236. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,512] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 3 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613237. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,519] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 4 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613238. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,948] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 4 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613239. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:27,955] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 5 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613239. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:28,007] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 5 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:28,013] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 6 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:28,514] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 6 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:28,520] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 7 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,022] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 7 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,028] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 8 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,529] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 8 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,534] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 9 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613240. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,592] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 9 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:29,598] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 10 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:30,098] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 10 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:30,104] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 11 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:30,605] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 11 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:30,611] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 12 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:31,113] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 12 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:31,118] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 13 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:31,618] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 13 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:31,624] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 14 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,124] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 14 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,130] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 15 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613241. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,175] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 15 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613242. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,182] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 16 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613242. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,380] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 16 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613243. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,386] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 17 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613243. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,887] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 17 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613243. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:32,893] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 18 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613243. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,274] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 18 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613244. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,281] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 19 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613244. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,509] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 19 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613245. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,516] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 20 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613245. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,951] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 20 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613246. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:33,958] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 21 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613246. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,073] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 21 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613247. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,079] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 22 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613247. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,207] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 22 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613248. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:149) at kafka.server.KafkaApis$$anonfun$maybeUnblockDelayedFetchRequests$2.apply(KafkaApis.scala:148) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.server.KafkaApis.maybeUnblockDelayedFetchRequests(KafkaApis.scala:148) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:166) at kafka.server.KafkaApis$$anonfun$handleProducerRequest$2.apply(KafkaApis.scala:165) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) at scala.collection.Iterator$class.foreach(Iterator.scala:772) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:165) at kafka.server.KafkaApis.handle(KafkaApis.scala:65) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,213] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 23 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613248. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,714] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 23 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613248. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:34,719] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 24 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613248. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296) at kafka.server.KafkaApis.handle(KafkaApis.scala:66) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:35,220] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 24 (kafka.server.KafkaApis) kafka.common.OffsetOutOfRangeException: Request for offset 0 but we only have log segments in the range 1195016 to 1613248. at kafka.log.Log.read(Log.scala:429) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Map$Map1.map(Map.scala:107) at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:579) at kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis.scala:561) at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:216) at java.lang.Thread.run(Thread.java:724) [2013-11-24 21:14:35,226] ERROR [KafkaApi-3] Error when processing fetch request for partition [testlogs,1] offset 0 from follower with correlation id 25 (kafka.server.KafkaApis)