[KAFKA-860] Replica fetcher thread errors out and dies during rolling bounce of cluster

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Component/s: replication
• Labels: kafka-0.8 p1
• Assignee: Neha Narkhede
• Reporter: Neha Narkhede
• Created: 10/Apr/13 21:12
• Updated: 30/Apr/13 17:14
• Resolved: 30/Apr/13 17:14

Description

2013/04/10 20:04:32.071 ERROR [ReplicaFetcherThread] [ReplicaFetcherThread-0-272] [kafka] [] [ReplicaFetcherThread-0-272], Error due to
kafka.common.KafkaException: error processing data for topic PageViewEvent partititon 3 offset 2482625623
at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4.apply(AbstractFetcherThread.scala:135)
at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4.apply(AbstractFetcherThread.scala:113)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:113)
at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:89)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
Caused by: java.lang.RuntimeException: Offset mismatch: fetched offset = 2482625623, log end offset = 2482625631.
at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:49)
at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4.apply(AbstractFetcherThread.scala:132)
... 5 more

This causes replica fetcher thread to shut down

Issue Links

• contains: KAFKA-862 Error incrementing leader high watermark