DynamicThreadPool

DynamicThreadPool is a BrokerReconfigurable for the following dynamic configurations:

Tip

Use kafka-configs shell script to alter a dynamic configuration:

$ ./bin/kafka-configs.sh \
  --bootstrap-server :9092 \
  --alter \
  --entity-type brokers \
  --entity-name 0 \
  --add-config num.recovery.threads.per.data.dir=2

DynamicThreadPool is created exclusively when DynamicBrokerConfig is requested to addReconfigurables (when KafkaServer is requested to start up).

DynamicThreadPool takes a single KafkaServer to be created.

Reconfiguring — reconfigure Method

reconfigure(
  oldConfig: KafkaConfig,
  newConfig: KafkaConfig): Unit
Note
 reconfigure is part of the BrokerReconfigurable Contract to change (reconfigure) the value of a Kafka dynamic configuration.

reconfigure…​FIXME

results matching ""

    No results matching ""