Kafka在v2.3版本中引入了动态配置更新的功能,允许管理员在运行时更改kraft controller的配置,而不需要重新启动整个Kafka实例。下面是一个示例:
dynamic.configs.enabled=true
controller.listener.names=myFirstListenerName
myFirstListenerName.bootstrap.servers=localhost:9092
bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type listeners --entity-name myFirstListenerName --alter --add-config bootstrap.servers=NEW_SERVER:NEW_SERVER_PORT
注意,如果您在Kafka集群中使用TLS,则需要将证书和密钥文件添加到命令中。
参考文献:https://kafka.apache.org/documentation/#dynamic-configs
上一篇:ApacheKafkaKRaft-KafkaStorageTool的中文翻译及代码示例解决方法。
下一篇:ApacheKafkaKraftQuorumControllerEventHandlerprocessBrokerHeartbeat:由于NotControllerException无法启动处理过程。