kafka添加用户密码

kafka添加用户密码

   小白     2022年1月25日 06:45     457    

这里添加密码是客户端在链接kafka的时候需要配置相应的用户和密码。

 

(1)首先修改配置文件

kafka的配置文件的目录下的 server.properties添加以下配置

listeners=SASL_PLAINTEXT://xx.xx.xx.xx:9092

security.inter.broker.protocol=SASL_PLAINTEXT

sasl.enabled.mechanisms=PLAIN

sasl.mechanism.inter.broker.protocol=PLAIN

 

这里的认证方式选择SASL_PLAINTEXT方式。

 

(2) 在配置文件目录中添加文件kafka_server_jaas.conf

KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin"
user_admin="admin"

user_count="123456"
};

 

usernamepassword是集群中,broker之间进行通讯

user_xxx是客户端(producerconsumer)连接broker时所用账号和密码

xxx是账号,等号后边是密码

 

(3) 在启动文件中配置

为了使用添加的配置文件需要在kafka-server-start.sh文件中添加配置

export KAFKA_OPTS="-Djava.security.auth.login.config=/root/kafka/config/kafka_server_jaas.conf"

然后重启kafka

 

这样就配置好了在访问kafka的时候需要输入用户名和密码。

 

(4) 使用python链接

producer = KafkaProducer(
sasl_mechanism="PLAIN",
security_protocol="SASL_PLAINTEXT",
sasl_plain_username="admin",
sasl_plain_password="admin",
bootstrap_servers=['192.168.15.6:9092'])

 

(5) 使用客户端链接

image.png

lQLPDhsVsTtFv33NAVnNBBewFc7P2CDBU2EB9DbBHsBsAA_1047_345.png 

image.png

 org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin";


文章评论

0

其他文章