[KAFKA-4027] Leader for a cetain partition unavailable forever

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.10.0.0
• Component/s: core
• Assignee: Unassigned
• Reporter: tu nguyen khac
• Created: 10/Aug/16 04:57
• Updated: 14/Mar/18 10:01
• Resolved: 13/Mar/18 16:29

Description

I have a cluster of brokers ( 9 box) , i 'm naming it from 0 --> 8 .
Yesterday some servers went down ( hard reset ) i regularly restart these server ( down servers ) but after that some topics cannot assign leader
i checked server log and retrieved these logging :

kafka.common.NotAssignedReplicaException: Leader 1 failed to record follower 6's position -1 since the replica is not recognized to be one of the assigned replicas 1 for partition [tos_htv3tv.com,31].
at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:251)
at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:864)
at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:861)
at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221)
at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428)
at kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:861)
at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:470)
at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:496)
at kafka.server.KafkaApis.handle(KafkaApis.scala:77)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
at java.lang.Thread.run(Thread.java:745)
i tried to run Prefered Leader but it didn't work ( some partitions has node leader )

Issue Links

• is related to: KAFKA-5758 Reassigning a topic's partitions can adversely impact other topics