dajac commented on code in PR #12240:
URL: https://github.com/apache/kafka/pull/12240#discussion_r890963791
##########
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java:
##########
@@ -485,12 +541,36 @@ Iterator<UsableBroker> usableBrokers() {
id -> brokerRegistrations.get(id).rack());
}
+ /**
+ * Returns true if the broker is in fenced state; Returns false if it is
+ * not or if it does not exist.
+ */
public boolean unfenced(int brokerId) {
Review Comment:
That's right. However, it is used in many places in the tests. I haven't
found a good way to replace it in tests that is as convenient as this
predicate. I would keep it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
