哪些ppt网站是免费的,专业做网盘资源收录分享的网站,影院网站建设,深圳家居网站建设公司排名文章目录 前言下载 kafka安装启动zookeeper添加账号密码 启动kafka修改kafka配置文件增加jaas授权文件修改启动文件#xff0c;启动kafka检查是否部署成功 offset explore 连接 前言
其实挺简单的几个配置文件#xff0c;问大模型一直没说到点上#xff0c;绕晕了。SASL/SC… 文章目录 前言下载 kafka安装启动zookeeper添加账号密码 启动kafka修改kafka配置文件增加jaas授权文件修改启动文件启动kafka检查是否部署成功 offset explore 连接 前言
其实挺简单的几个配置文件问大模型一直没说到点上绕晕了。SASL/SCRAM 的认证涉及到要先在 zookeeper 上创建好认证信息最后慢慢捋下来其实就这么几个配置和命令。
下载 kafka
下载地址https://kafka.apache.org/downloads 我下载的版本是 3.6.0 https://archive.apache.org/dist/kafka/3.6.0/kafka_2.12-3.6.0.tgz
安装
解压文件到指定解压的目录下
tar -zxvf kafka_2.12-3.6.0.tgz
cd kafka_2.12-3.6.0启动zookeeper
kafka 的目录本身是带有 zookeeper 的我们可以直接使用不需要再去下载一个 zookeeper。 如果本身已经在电脑上装过了把 /tmp 目录下的 kafka-log、zookeeper 目录删除 bin/zookeeper-server-start.sh config/zookeeper.properties添加账号密码 先添加账号密码否则先启动kafka会一直输出授权错误 ./kafka-configs.sh --zookeeper localhost:2181 --alter --add-config SCRAM-SHA-256[password你的密码],SCRAM-SHA-512[password你的密码] --entity-type users --entity-name 用户名启动kafka
修改kafka配置文件 在最后添加这几行配置就可以 listenersSASL_PLAINTEXT://127.0.0.1:9092
security.inter.broker.protocolSASL_PLAINTEXT
sasl.mechanism.inter.broker.protocolSCRAM-SHA-256
sasl.enabled.mechanismsSCRAM-SHA-256增加jaas授权文件 这个文件随便放哪里最后要在启动命令文件里面指定 KafkaServer {org.apache.kafka.common.security.scram.ScramLoginModule requiredusername用户名password你的密码;
};修改启动文件启动kafka
vi bin/kafka-server-start.sh
# 放在 exec 命令之前
export KAFKA_OPTS-Djava.security.auth.login.config前面的文件路径
# 保存文件退出# 执行启动命令
bin/kafka-server-start.sh config/server.properties检查是否部署成功
cat sasl_plaintext.cfg EOF
sasl.jaas.configorg.apache.kafka.common.security.scram.ScramLoginModule required username用户名 password你的密码;
security.protocolSASL_PLAINTEXT
sasl.mechanismSCRAM-SHA-256
EOF./kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --command-config 文件夹目录/sasl_plaintext.cfg --list正常输出的话就是部署成功了。
offset explore 连接
security 选择好类型 advanced 配置 mechanism 为 SCRAM-SHA-256
jaas config 增加配置
org.apache.kafka.common.security.scram.ScramLoginModule required username用户名 password你的密码;
