THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
--command-config
option will be also added. This would accept a file argument that points to the AdminClient configuration connection properties file (such as SSL, buffers, etc.).
Code Block | ||||
---|---|---|---|---|
| ||||
val bootstrapServerOpt = parser.accepts("bootstrap-server", "REQUIRED: The Kafka servers to connect to, separated by commas, for instance "localhost:9091,localhost:9092". In case of providing this, a direct Zookeeper connection won't be required.") .withRequiredArg .describedAs("server to connect to") .ofType(classOf[String]) val commandConfigOpt = parser.accepts("command-config", "Property file containing connection configs to be passed to Adminthe ClientAdminClient. " + "This is used only with --bootstrap-server option.") .withRequiredArg .describedAs("command config property file") .ofType(classOf[String]) |
...