我已经使用
根据这份文档 - http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs,我们可以使用
上述文档有一个配置列,其中写着-
我尝试通过以下命令更新
如何传递的值以动态更新jaas配置?
sasl.jaas.config
属性设置了kafka的jaas配置。我想更新此配置并动态添加用户。根据这份文档 - http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs,我们可以使用
bin/kafka-configs.sh
来实现。上述文档有一个配置列,其中写着-
![enter image description here](https://istack.dev59.com/esLyW.webp)
sasl.jaas.config
:
bin/kafka-configs.sh --bootstrap-server localhost: 9092 --entity-type brokers --entity-name 59 --alter --add-config sasl.jaas.config = "KafkaServer {\ n org.apache.kafka.common.security.plain.PlainLoginModule required \ n username = \"myuser\" \n password = \"mypassword\"; \ n}; \ nClient {\ n org.apache.zookeeper.server.auth.DigestLoginModule required \ n username = \"myuser2\" \n password = \"mypassword2\"; \ n};"
但是它给我以下错误:
requirement failed: Invalid entity config: all configs to be added must be in the format "key=val"
如果我看上面的列,它说sasl.jaas.config
属性的值格式为(=)*
。这是什么意思?如何传递的值以动态更新jaas配置?
alterConfigs()
的Javadocs http://kafka.apache.org/21/javadoc/org/apache/kafka/clients/admin/AdminClient.html#alterConfigs-java.util.Map- 有关示例,请参见https://stackoverflow.com/questions/54024829/java-kafka-adminclient-topic-configuration-configuration-values-are-overwritten/54026448#54026448 - Mickael Maison