kafka windows环境搭建 SASL_PLAINTEXT/SCRAM
kafka windows环境搭建 SASL_PLAINTEXT/SCRAM acl认证记录
一、kafka 下载参考地址
https://kafka.apache.org/downloads
二、环境准备
1)64 bit JDK 1.8+;下载 & 配置。
2)zookeeper,因kafka内置zookeeper,故不需要下载和配置
三、修改配置文件
这里主要修改四个配置文件server.properties、zookeeper.properties、consumer.properties 、producer.properties
1)server.properties
文件位置:kafka\config
#配置启动log存放位
log.dirs=D:\airlook_java_project\kafka_server/kafka-logs
sasl.enabled.mechanisms=SCRAM-SHA-256
sasl.mechanism.inter.broker.protocol=SCRAM-SHA-256
security.inter.broker.protocol=SASL_PLAINTEXT
listeners=SASL_PLAINTEXT://10.21.80.20:9092
listener.name.sasl_plaintext.scram-sha-256.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required
username=“admin”
password=“admin”;
#授权方面
#设置身份验证使用的类
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
#设置超级账号,如果是多个需要分号分割,例如:User:admin;User:root
super.users=User:admin
#对所有用户topic可见,要禁用。
allow.everyone.if.no.acl.found=false
2)zookeeper.properties
文件位置:kafka\config
dataDir=D:\airlook_java_project\kafka_server/data/zookeeper
#下面这几个参数似乎可以不配
maxClientCnxns=0
authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jssaLoginRenew=3600000
3)consumer.properties 、producer.properties 文件
文件位置:kafka\config
security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-256
#这是一行的配置,这里显示成了两行
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username=“admin” password=“admin”
4)创建授权配置文件 auth.conf 文件,供其他命令使用,比如创建topic ,查询topic,都需要改配置进行权限认证
文件位置:kafka\config
security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-256
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username=“admin” password=“admin”
四、授权
在D:\developSOFT\kafka\kafka_2.12-Jaas_Scram\bin\windows 文件夹内输入 cmd 进入dos命令窗口
#动态添加admin用户
kafka-configs.bat --zookeeper 127.0.0.1:2181 --alter --add-config SCRAM-SHA-256=[password=admin] --entity-type users --entity-name admin
五、启动命令
注意:在D:\developSOFT\kafka\kafka_2.12-Jaas_Scram\bin\windows 文件夹内输入 cmd 进入dos命令窗口
1、启动zookeeper服务
zookeeper-server-start.bat …/…/config/zookeeper.properties
2、关闭zookeeper服务
zookeeper-server-stop.bat …/…/config/zookeeper.properties
3、启动kafka
kafka-server-start.bat …/…/config/server.properties
4.关闭kafka ,也可使用 ctil + c 按键关闭
kafka-server-stop.bat …/…/config/server.properties
5、创建主题 test-topic
kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 3 --topic testxp command-config …/…/config/auth.conf
6、启动消费者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testxp --from-beginning --consumer.config …/…/config/consumer.properties
7、启动生产者
kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic testxp --producer.config …/…/config/producer.properties
8、查看消费组
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list --command-config …/…/config/auth.conf
9、查看主题命令
kafka-topics.bat --list --bootstrap-server localhost:9092 --command-config …/…/config/auth.conf
10、其他命令记录:
#添加test用户
kafka-configs.bat --zookeeper 127.0.0.1:2181 --alter --add-config SCRAM-SHA-256=[password=123456] --entity-type users --entity-name test
#给test 用户 赋予 testxp 的topic读权限
kafka-acls.bat --authorizer-properties zookeeper.connect=127.0.0.1:2181 --add --allow-principal User:“test” --consumer --topic ‘testxp’ --group ‘*’
#给test 用户赋予 testxp 的topic 写权限
kafka-acls.bat --authorizer-properties zookeeper.connect=127.0.0.1:2181 --add --allow-principal User:“test” --producer --topic ‘testxp’
参考链接:
https://www.jianshu.com/p/704ca9560718
kafaka 的授权认证 SASL/PLANTEXT ACL 参考地址: https://blog.csdn.net/weixin_41835653/article/details/124205519
kafka windows环境搭建 SASL_PLAINTEXT/SCRAM相关推荐
- Kafka单机Windows环境搭建
Kafka单机Windows环境搭建 1,安装jdk1.8:安装目录不能有中文空格: 2,下载zookeeper,https://mirrors.cnnic.cn/apache/zookeeper/z ...
- JAVA JDK windows环境搭建
JAVA JDK windows环境搭建 系统环境: windows 10 , JDK 1.7 操作步骤: 1.下载JDK,全部选择默认,直接点击下一步 2.配置环境变量 打开环境变量 变量设置 JA ...
- Flutter之Windows环境搭建
Flutter之Windows环境搭建 原创作者:只能陪你走一程 原文地址:https://www.jianshu.com/p/a78fd5e5116d 官方网址:https://flutter.io ...
- Windows 环境搭建 git 服务
Windows 环境搭建 git 服务 有时候在本地开发个人项目, 需要对代码进行版本管理, 可在 Windows 上搭建一个自己使用的 git 服务器 当前搭建系统环境 Windows10 安装Gi ...
- tinygo的windows环境搭建及简单例程
windows 环境搭建 安装 g 这里还是推荐g这个 go 的多版本管理工具,类似 NodeJS 的 nvm,Python 的 virtualenv. 官网下载: https://github.co ...
- RockChip Android平台抓取android trace的windows环境搭建
RockChip Android平台抓取android trace的windows环境搭建的步骤 安装python2.7.9 下载链接: https://www.python.org/download ...
- ESC32 windows 环境搭建【Visual Studio Code】
ESP32 windows 环境搭建 第一步:工具准备 1.Visual Studio Code下载 2.工具链下载 3.SDK下载 第二步:搭建环境 1.Visual Studio Code安装 2 ...
- 高通平台上的AMSS(Modem端) windows环境搭建
高通平台上的AMSS(Modeom端)Windows环境搭建 一.首先简单介绍一下,高通平台7&8系列平台的软硬件架构. 如图: 硬件上采用的是ARM9+ARM11(最新的采用Cotex-A8 ...
- Windows环境搭建WeGame饥荒专用服务器(详细版)
Windows环境搭建WeGame饥荒专用服务器 前言 饥荒专用服务器 获取cluster_token令牌 注册许可证书 文件配置 路径配置 根目录 cluster.ini文件配置 地面服务器(Mas ...
最新文章
- Java黑皮书课后题第5章:**5.7(金融应用:计算将来的学费)假设今年某大学的大学为10000美元,学费的年增长率为5%,一年后,学费将是10500美元。编写程序,计算10年后的学费,10~13费
- 转:10个常见的 Android 新手误区
- ajax put请求_前端基础面试:手写一个ajax,说说XMLHttpRequest 都有哪些属性?
- word受权限保护无法打开_保护S71500程序的几种方式
- World Wind Java开发之三 显示状态栏信息(转)
- IIS 6.0曝远程代码执行漏洞 安全狗可拦截
- YII with()
- 《ARM嵌入式Linux系统开发从入门到精通》勘误
- Java常用中间件---SpringBoot整合ActivityMQ
- Win10开始菜单美化:磁贴放置分块图片
- 23个无本空手套白狼的赚钱方法!颠…
- 【Python-Anaconda】jupyter notebook运行代码时出现异常——代码前面的[ ]中为空,跳转下一行,显示自动保存失败。面对这种情况该如何解决?
- C++ 使用fdk-aac对音频编码
- 如何根据样本估计总体的均值、比例与方差?如何进行参数估计及选择对应公式?
- php strstr批量替换,也就这样,
- sap采购申请自动转采购订单
- JavaScript面试问题:事件委托和this
- Jmeter连接sqlSever踩的坑
- Python入门(第一节):Python版本如何选和安装
- Java保留小数点后两位方法(推荐使用NumberFormat)