[ https://issues.apache.org/jira/browse/KAFKA-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-4305. -------------------------------- Resolution: Duplicate Thanks for the report, this is a duplicate of KAFKA-4205. > Possible race condition in log segment truncation and Kafka Request Handler > ---------------------------------------------------------------------------- > > Key: KAFKA-4305 > URL: https://issues.apache.org/jira/browse/KAFKA-4305 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.10.0.1 > Reporter: Hari > Priority: Minor > Labels: reliability > > We started to observe this trace in our Kafka Server logs after migration to > 0.10.0.1 > {code} > [2016-10-16 20:55:04,825] ERROR [KafkaApi-303] Error while responding to > offset request (kafka.server.KafkaApis) > java.lang.NullPointerException > at kafka.server.KafkaApis.fetchOffsetsBefore(KafkaApis.scala:585) > at kafka.server.KafkaApis.fetchOffsets(KafkaApis.scala:573) > at kafka.server.KafkaApis$$anonfun$27.apply(KafkaApis.scala:530) > at kafka.server.KafkaApis$$anonfun$27.apply(KafkaApis.scala:521) > 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.Iterator$class.foreach(Iterator.scala:727) > at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) > at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) > at scala.collection.AbstractIterable.foreach(Iterable.scala:54) > at > scala.collection.TraversableLike$class.map(TraversableLike.scala:244) > at scala.collection.AbstractTraversable.map(Traversable.scala:105) > at kafka.server.KafkaApis.handleOffsetRequest(KafkaApis.scala:521) > at kafka.server.KafkaApis.handle(KafkaApis.scala:78) > at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) > at java.lang.Thread.run(Thread.java:745) > {code} > From a quick investigation, I suspect this could happen because of race > condition with log segment truncation and Kafka request handler ? > Any thoughts ? -- This message was sent by Atlassian JIRA (v6.3.15#6346)