• 主页
• 运维
• 开发
• 公告
• 登录
• 注册

这里添加密码是客户端在链接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"
};

 

username和password是集群中，broker之间进行通讯

user_xxx是客户端（producer，consumer）连接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) 使用客户端链接

 

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