使用SASL_SSL协议访问集群 本文介绍创建完集群后,如何使用Kafka脚本通过SASL_SSL协议访问Kafka集群,SASL_SSL协议需要在 公网网络 下进行使用。如果想使用Java、Go、PHP等语言访问Kakfa集群,请参考 开发指南 。 前提条件 步骤一:创建Kafka集群 步骤二:创建主题 步骤三:配置权限认证 安装JDK1.8及以上版本: JDK下载地址 。
ssl.cert/ca.pem'); // SASL 机制 \$conf->set('sasl.mechanism','SCRAM-SHA-512'); // SASL 用户名 \$conf->set('sasl.username','alice'); // SASL 密码 \$conf->set('sasl.password','alice1234!')
ssl.endpoint.identification.algorithm' : 'none' , # 证书文件路径 'ssl.ca.location' : 'ca.pem' , # SASL 机制 'sasl.mechanism' : 'SCRAM-SHA-512' , # SASL 用户名 'sasl.username' : 'username' , # SASL 用户密码 'sasl.password
证书文件路径 ssl.ca.location : ca.pem , // SASL 机制 sasl.mechanism : SCRAM-SHA-512 , // SASL 用户名 sasl.username : alice , // SASL 用户密码 sasl.password : alice1234!
公网SASL_SSL方式生产和消费消息 在 Kafka 集群所在 VPC 网络外访问,使用 SASL_SSL 协议接入,接入点可以在 集群详情 页面查看。 环境准备 安装1.8或以上版本 JDK 安装2.5或以上版本 Maven 集群准备 1. 购买专享版消息服务for Kafka集群 开通消息服务 for Kafka服务后,在控制台页面点击『创建集群』,即可进行购买。 2.
公网SASL_SSL方式生产和消费消息 在 Kafka 集群所在 VPC 网络外访问,使用 SASL_SSL 协议接入,接入点可以在 集群详情 页面查看。 环境准备 安装GCC 安装C++ 依赖库。 yum install librdkafka-devel yum install cyrus-sasl yum install cyrus-sasl-scram 集群准备 1.
conf->set('sasl.username','alice'); // SASL 密码 \$conf->set('sasl.password','alice1234!')
none', # 'ssl.ca.location':'client.truststore.pem', # SASL 机制 'sasl.mechanism' : 'SCRAM-SHA-512' , # SASL 用户名 'sasl.username' : 'username' , # SASL 用户密码 'sasl.password' : 'password' } ) def callback_msg
SASL 机制 sasl.mechanism : SCRAM-SHA-512 , // SASL 用户名 sasl.username : alice , // SASL 用户密码 sasl.password : alice1234!
security.protocol 固定为 SASL_PLAINTEXT sasl.mechanism 固定为 SCRAM-SHA-512或者PLAIN,根据集群所使用的认证方式进行选择 java.security.auth.login.config 配置为 kafka_client_jaas.conf 路径 security.protocol=SASL_PLAINTEXT sasl.mechanism