Kafka

2023-05-09 16:06| 来源: 网络整理| 查看: 265

Kafka—配置SASL/PLAIN认证客户端及常用操作命令原创

Andya_net 2023-05-08 15:58:27 博主文章分类：Hadoop大数据专栏 ©著作权

文章标签 kafka hadoop bootstrap 客户端文章分类 MySQL 数据库

©著作权归作者所有：来自51CTO博客作者Andya_net的原创作品，请联系作者获取转载授权，否则将追究法律责任

介绍

SASL/PLAIN 是一种简单的 username/password安全认证机制，本文主要总结服务端开启该认证后，命令行客户端进行配置的操作流程。

配置增加jaas.properties

在kafka的config目录下增加jaas.properties文件指定认证协议为SASL_PLAINTEXT

security.protocol=SASL_PLAINTEXT sasl.mechanism=PLAIN增加kafka_client_jaas.conf

配置客户端JAAS文件，在kafka的config目录下添加kafka_client_jaas.conf文件配置KafkaClient

KafkaClient { org.apache.kafka.common.security.plain.PlainLoginModule required username="user01" password="user01@123" };修改对应启动脚本

可以修改kafka-topic.sh、kafka-console-producer.sh、kafka-console-consumer.sh启动脚本，增加export信息export KAFKA_OPTS=" -Djava.security.auth.login.config=/opt/kafka_2.11-2.2.2/config/kafka_client_jaas.conf

操作执行查看topic列表list./bin/kafka-topic.sh --bootstrap-server localhost:9092 --command-config config/jaas.properties --list查看详情describe./bin/kafka-topic.sh --bootstrap-server localhost:9092 --command-config config/jaas.properties --describe --topic topic01生产producer./bin/kafka-console-producer.sh --broker-list localhost:9092 --producer-config config/jaas.properties --topic topic01消费consumer./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --consumer-config config/jaas.properties --group group01 --topic topic01查看消费组./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --command-config config/jaas.properties --group group01 --describe

赞收藏评论分享举报

上一篇：SpringBoot——项目启动时读取配置及初始化资源

下一篇：JVM——字符串常量池详解

【本文地址】

公司简介

联系我们