[ https://issues.apache.org/jira/browse/KAFKA-12677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322747#comment-17322747 ]
Luke Chen commented on KAFKA-12677: ----------------------------------- [~cmccabe], could you take a look at this bug? If you are busy, you can also guide me where to look into. Thank you. > The raftCluster always send to the wrong active controller and never update > --------------------------------------------------------------------------- > > Key: KAFKA-12677 > URL: https://issues.apache.org/jira/browse/KAFKA-12677 > Project: Kafka > Issue Type: Bug > Components: core > Reporter: Luke Chen > Priority: Major > > We introduce KIP-500 to introduce a Self-Managed Metadata Quorum. We should > always have 1 active controller, and all the RPC will send to the active > controller. But there's chances that the active controller already changed, > but the RPC still send to the old one. > In the attachment log, we can see: > {code:java} > [Controller 3002] Becoming active at controller epoch 1. > ... > [Controller 3000] Becoming active at controller epoch 2. > {code} > So, the latest active controller should be 3000. But the create topic RPC are > all sending to controller 3002: > {code:java} > "errorMessage":"The active controller appears to be node 3000" > {code} > This bug causes the RaftClusterTests flaky. -- This message was sent by Atlassian Jira (v8.3.4#803005)