...
Public Interfaces
Add optional argument "commandconfig-configfile" to both kafka-reassign-partitions.sh and kafka-log-dirs.sh with the following specification
Code Block |
---|
parser.accepts("commandconfig-configfile", "Property file containing configs to be passed to Admin Client.") .withRequiredArg .describedAs("command config property file") .ofType(classOf[String]) |
Proposed Changes
When "--commandconfig-configfile" is specified by user, the property file will be used to instantiate the AdminClient used by these tools. This is the same approach used by "--commandconfig-configfile" in ConfigCommand.
The bootstrap url specified by "--bootstrap-server" option will take precedence over the bootstrap.servers specified in the property file.
...