[GitHub] [kafka] cmccabe commented on a change in pull request #10688: KAFKA-12778: Fix QuorumController request timeouts and electLeaders

cmccabe commented on a change in pull request #10688: URL: https://github.com/apache/kafka/pull/10688#discussion_r632697059 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -800,19 +800,44 @@ void handleBrokerUnfenced(int br

[GitHub] [kafka] cmccabe commented on a change in pull request #10688: KAFKA-12778: Fix QuorumController request timeouts and electLeaders

cmccabe commented on a change in pull request #10688: URL: https://github.com/apache/kafka/pull/10688#discussion_r632696250 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -1165,4 +1192,22 @@ public long curClaimEpoch() { publi

[GitHub] [kafka] cmccabe commented on a change in pull request #10688: KAFKA-12778: Fix QuorumController request timeouts and electLeaders

cmccabe commented on a change in pull request #10688: URL: https://github.com/apache/kafka/pull/10688#discussion_r632695450 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -1030,17 +1050,24 @@ private QuorumController(LogContext log

[GitHub] [kafka] cmccabe commented on a change in pull request #10688: KAFKA-12778: Fix QuorumController request timeouts and electLeaders

cmccabe commented on a change in pull request #10688: URL: https://github.com/apache/kafka/pull/10688#discussion_r632695254 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -1002,7 +1013,13 @@ private QuorumController(LogContext logC