Hari created KAFKA-4305: --------------------------- Summary: 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
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.4#6332)