• Dynamic Kafka Configurations


    Some of the Apache Kafka® broker and topic configurations can be updated without restarting the broker. This section talks about updating these configuration options dynamically and securing password configurations by storing them in encrypted form in ZooKeeper.

    Changing Broker Configurations Dynamically

    Some of the broker configurations can be updated without restarting the broker. See the Dynamic Update Mode option in Broker Configurations for the update mode of each broker configuration.

    • read-only: Requires a broker restart for update.
    • per-broker: May be updated dynamically for each broker.
    • cluster-wide: May be updated dynamically as a cluster-wide default. May also be updated as a per-broker value for testing.

    To alter the current broker configurations for broker ID 0 (for example, the number of log cleaner threads):

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --add-config log.cleaner.threads=2
    

    To alter several configurations at the same time, or to alter configurations with complex values (for example, the Router config for Audit Logs), create a file with the desired values in .properties format and use --add-config-file. If you have the new configurations in a file named new.properties:

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-default --alter --add-config-file new.properties
    

    To describe the current dynamic broker configs for broker ID 0:

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --describe
    

    To delete a configuration override and revert to the statically configured or default value for broker ID 0 (for example, the number of log cleaner threads):

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --delete-config log.cleaner.threads
    

    Some configurations may be configured as a cluster-wide default to maintain consistent values across the whole cluster. All brokers in the cluster will process the cluster default update. For example, to update log cleaner threads on all brokers:

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-default --alter --add-config log.cleaner.threads=2
    

    To describe the currently configured dynamic cluster-wide default configurations:

    bin/kafka-configs --bootstrap-server localhost:9092 --entity-type brokers --entity-default --describe
    

    All configurations that are configurable at cluster level may also be configured at per-broker level (e.g. for testing). If a configuration value is defined at different levels, the following order of precedence is used:

    • Dynamic per-broker config stored in ZooKeeper
    • Dynamic cluster-wide default config stored in ZooKeeper
    • Static broker config from server.properties
  • 相关阅读:
    SQL Server 阻止了对组件 ‘Ole Automation Procedures‘ 的 过程‘sys.sp_OACreate‘ 的访问
    堆 超详细的带图总结
    2024抖音矩阵云混剪系统源码 短视频矩阵营销系统
    SWT/ANR问题--AMS/WMS
    使用 Go 写入文件
    嵌入式C语言知识复习和提高
    【2022秋招面经】——Django
    军队状态出现的六种结果,是将帅的过失
    ES入门七:索引管理Api的使用
    CC0是什么,为什么它会改变NFT市场?
  • 原文地址:https://blog.csdn.net/qq_32907195/article/details/126488579