mimaison commented on code in PR #21273:
URL: https://github.com/apache/kafka/pull/21273#discussion_r2832683559
##########
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##########
@@ -577,8 +577,20 @@ class DynamicLogConfig(logManager: LogManager) extends
BrokerReconfigurable with
}
}
+ def validateCordonedLogDirs(): Unit = {
Review Comment:
This validation happens on the configurations provided in the file when
starting the broker. If you remove an entry from `log.dirs` you should also
remove it from `cordoned.log.dirs`.
If you've previously cordoned a log directory via the Admin API, even if you
remove that directory from your configuration file, the broker should still
start. You can then use the Admin API again to clear the old cordoned log
directory that is not used anymore.
--
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]
