为kafka添加用户以及密码,SASL/PLAIN
事先声明,有版本的问题,修改之前请备份好原配置文件在修改!!!1.先找到该文件添加以下内容# 添加下面的配置ip和端口改成自己需要listeners=SASL_PLAINTEXT://xx.xx.xx.xx:8123security.inter.broker.protocol=SASL_PLAINTEXTsasl.enabled.mechanisms=PLAINsasl.m...
·
事先声明,有版本的问题,修改之前请备份好原配置文件在修改!!!
1.先找到该文件
添加以下内容
# 添加下面的配置 ip和端口改成自己需要
listeners=SASL_PLAINTEXT://xx.xx.xx.xx:8123
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
接下来创建一个文件,文件名为 kafka_server_jaas.conf
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="kafka"
password="admin"
user_kafka="kafkapswd"
user_zhb="123456";
};
#其中username和password用于brokers和zk进行认证,user_*用于zk client与zk server进行认证
#user_zhb="123456" 表示 zhb为用户名,123456为密码
接下来添加kafka_client_jaas.conf文件并写入以下内容
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="zhb"
password="123456";
};
接下来是重点,修改kafka的启动文件kafka-server-start.sh
if [ "x$KAFKA_OPTS" ]; then
export KAFKA_OPTS="-Djava.security.auth.login.config=D:\消息队列\kafka_2.11-2.3.1\config\kafka_server_jaas.conf"
fi
收工完事
更多推荐
已为社区贡献2条内容
所有评论(0)