jsancio commented on a change in pull request #11893:
URL: https://github.com/apache/kafka/pull/11893#discussion_r828545811
##########
File path:
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
##########
@@ -1197,6 +1257,25 @@ private void resetState() {
*/
private long newBytesSinceLastSnapshot = 0;
+ /**
+ * How long to delay partition leader balancing operations.
+ */
+ private final long leaderImbalanceCheckIntervalNs;
+
+ private static enum ImbalanceSchedule {
+ // Leader balancing has been scheduled
+ SCHEDULED,
+ // Leader balancing should be scheduled in the future
+ DEFERRED,
Review comment:
Yes. I fixed the documentation for these values to make this clear.
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
