使用 SASL/PLAIN 认证
配置Kafka Broker
添加JAAS文件,这个例子的配置文件是每个broker的配置目录,命名为 kafka_server_jaas.conf。
KafkaServer {
     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动态增加一个用户名和密码。