ConfigCommand Standalone Application

kafka.admin.ConfigCommand is a standalone application that…​FIXME

ConfigCommand can be executed using kafka-configs shell script (i.e. bin/kafka-configs.sh or bin\windows\kafka-configs.bat).

// Triggers alterBrokerConfig
./bin/kafka-configs.sh \
  --bootstrap-server :9092 \
  --alter \
  --entity-type brokers \
  --entity-name 0 \
  --add-config advertised.listeners=plaintext://:9092
// Triggers processBrokerConfig
./bin/kafka-configs.sh \
  --bootstrap-server :9092 \
  --describe \
  --entity-type brokers \
  --entity-name 0

alterBrokerConfig Method

alterBrokerConfig(
  adminClient: JAdminClient,
  opts: ConfigCommandOptions,
  entityName: String)

alterBrokerConfig…​FIXME

Note
alterBrokerConfig is used exclusively when ConfigCommand is requested to processBrokerConfig (with alter action).

processBrokerConfig Internal Method

processBrokerConfig(opts: ConfigCommandOptions): Unit

processBrokerConfig…​FIXME

Note
processBrokerConfig is used exclusively when ConfigCommand standalone application is executed (without zookeeper command-line option).

Executing Standalone Application — main Method

main(args: Array[String]): Unit

main is the entry point of the ConfigCommand standalone application when launched on command line (e.g. from bin/kafka-configs.sh).

main…​FIXME

processCommandWithZk Internal Method

processCommandWithZk(zkConnectString: String, opts: ConfigCommandOptions): Unit

processCommandWithZk…​FIXME

Note
processCommandWithZk is used when…​FIXME

alterConfig Internal Method

alterConfig(
  zkClient: KafkaZkClient,
  opts: ConfigCommandOptions,
  adminZkClient: AdminZkClient): Unit

alterConfig…​FIXME

Note
alterConfig is used when…​FIXME

results matching ""

    No results matching ""