[ https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13688871#comment-13688871 ]
Dibyendu Bhattacharya commented on KAFKA-948: --------------------------------------------- I have tested a Fix, which seems to be working fine. For ReplicaStateMachine.scala, the handleStateChange method for offlineReplica case, the currLeaderIsrAndControllerEpoch.leaderAndIsr.isr contains the stale entry. A call to updateLeaderAndIsrCache() before will solve this issue. Shall I go ahead and make a pull request with this fix ? Dibyendu > ISR list in LeaderAndISR path not updated for partitions when Broker (which > is not leader) is down > -------------------------------------------------------------------------------------------------- > > Key: KAFKA-948 > URL: https://issues.apache.org/jira/browse/KAFKA-948 > Project: Kafka > Issue Type: Bug > Components: controller > Affects Versions: 0.8 > Reporter: Dibyendu Bhattacharya > Assignee: Neha Narkhede > > When the broker which is the leader for a partition is down, the ISR list in > the LeaderAndISR path is updated. But if the broker , which is not a leader > of the partition is down, the ISR list is not getting updated. This is an > issues because ISR list contains the stale entry. > This issue I found in kafka-0.8.0-beta1-candidate1 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira