Kafka 设置用户密码

一 下载

官网 https://kafka.apache.org/downloads

wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.2/kafka_2.12-2.6.2.tgz
tar -xzf kafka_2.12-2.6.2.tgz

二 设置kafka用户名密码

1. 增加用户密码配置文件
   在config下面新建kafka_client_jaas.conf文件内容如下

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

在config下面新建kafka_client_jaas.conf文件内容如下

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

2 修改启动脚本
vim bin/kafka-server-start.sh

# 最上面加上(路径改为自己的)
export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_server_jaas.conf"

vim bin/kafka-console-producer.sh , vim bin/kafka-console-consumer.sh

最上面加上(路径改为自己的)
export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_client_jaas.conf"

3 修改配置文件
vim config/server.properties

# 必须使用真实ip地址
listeners=SASL_PLAINTEXT://192.168.1.110:9092

#使用的认证协议
security.inter.broker.protocol=SASL_PLAINTEXT
#SASL机制
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
#完成身份验证的类
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
#如果没有找到ACL（访问控制列表）配置，则允许任何操作。
#allow.everyone.if.no.acl.found=true
#需要开启设置超级管理员, 开启以下命令
super.users=User:admin
#delete.topic.enable=true
#auto.create.topics.enable=false

config下consumer.properties和producer.properties添加命令

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN

三 启动kafka
启动zookeeper

./bin/zookeeper-server-start.sh config/zookeeper.properties
# 后台启动
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

启动kafka

./bin/kafka-server-start.sh config/server.properties
# 后台启动
./bin/kafka-server-start.sh -daemon config/server.properties

启动生产者

bin/kafka-console-producer.sh --bootstrap-server 192.168.50.131:9092 --topic test --producer.config config/producer.properties

启动消费者

bin/kafka-console-consumer.sh --bootstrap-server 192.168.50.131:9092 --topic test --from-beginning --consumer.config config/consumer.properties

四 kafka tool 连接

下载 https://www.kafkatool.com/download.html
用户名密码连接
properties

输入zk地址和端口和kafka版本号，其他随意

security

Type: SASL Planintext

Advanced

Bootstrap servers: 192.168.x.x:9092
SASL Mechanism: PLAIN

JAAS Config

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

显示字符串信息

# 显示topic的信息
tools--settings--topics--key/value -- 改为string类型

参考
https://zhuanlan.zhihu.com/p/301343840
https://www.jianshu.com/p/806545fc0a28
https://www.kafkatool.com/download.html