[ 
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

Reply via email to