hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r685421603
##
File path:
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
##
@@ -858,7 +858,7 @@ private void rescheduleMaybeFenceStaleBro
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r685463058
##
File path:
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
##
@@ -858,7 +858,7 @@ private void rescheduleMaybeFenceStaleBro
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r686135001
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -419,6 +419,27 @@ long nextCheckTimeNs() {
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687186647
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigurat
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687194150
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigurat