返回到文章

采纳

编辑于

使用 SASL/PLAIN 动态更新用户名和密码?

kafka

使用 SASL/PLAIN 认证

配置Kafka Broker

添加JAAS文件,这个例子的配置文件是每个broker的配置目录,命名为 kafka_server_jaas.confKafkaServer {
     org.apache.kafka.common.security.plain.PlainLoginModule required
     username="admin"
     password="admin-secret"
     user_admin="admin-secret"
     user_alice="alice-secret";
 };

如何在kafka进程启动之后,在不重启kafka进程的情况下,在kafka_server_jaas.conf动态增加一个用户名和密码。