[
https://issues.apache.org/jira/browse/KAFKA-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-4305:
-------------------------------
Labels: reliability (was: )
> 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.4#6332)
