KafkaBrokerSASL-NoAuthException-KeeperErrorCodeNoAuthfor/brokers/ids

这个问题是由于Kafka代理缺少所需的授权或权限配置引起的。解决此问题需要在Kafka代理的配置文件中添加必要的授权和权限信息，以确保代理能够正确访问ZooKeeper，并获取所需的Brokers列表。

例如，在Kafka的server.properties配置文件中添加以下SASL相关的配置：

# SASL认证配置
listeners=SASL_PLAINTEXT://:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN

# ZooKeeper配置
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=6000
zookeeper.set.acl=true
zookeeper.sasl.client=false

您还需要为代理创建一个Kafka超级用户，并将其添加到授权列表中，以便针对代理进行SASL身份验证。

例如，在您的Kafka归档文件中，您可以使用以下命令基于用户名和密码创建一个Kafka超级用户：

bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[password=<您的密码>]]' --entity-type users --entity-name <您的用户名>

然后，您可以使用以下命令将用户作为超级用户添加到ACL列表中：

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:<您的用户名> --operation ALL --cluster

完成这些步骤后，您的Kafka代理应该可以恢复与ZooKeeper的连接，您的应用程序也应该能够顺利与Kafka代理进行通信。

本文内容通过AI工具匹配关键字智能整合而成，仅供参考，火山引擎不对内容的真实、准确或完整作任何形式的承诺。如有任何问题或意见，您可以通过联系service@volcengine.com进行反馈，火山引擎收到您的反馈后将及时答复和处理。

展开更多

开发者特惠

面向开发者的云福利中心，ECS 60元/年，域名1元起，助力开发者快速在云上构建可靠应用

ECS首年60元

社区干货

特惠活动

域名注册服务

cn/top/com等热门域名，首年低至1元，邮箱建站必选

￥1.00/首年起32.00/首年起

立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗，加速分发更实惠

￥2.00/年20.00/年

立即购买

KafkaBrokerSASL-NoAuthException-KeeperErrorCodeNoAuthfor/brokers/ids -优选内容

如何使用Nginx代理访问VPC内的自建Kafka

前言对于一些自建在VPC内的Kafka有暴露到外网的需求,那么我们就可以通过Nginx代理来做四层代理,转发请求。关于实验预计部署时间:30分钟级别:初级相关产品:同VPC内的ECS两台(1台做Nginx代理,1台做Kafka Server)受... nginx -V 2>&1 grep streamconfigure arguments: --prefix=/etc/nginx --sbin-path=/usr/sbin/nginx --conf-path=/etc/nginx/nginx.conf --error-log-path=/var/log/nginx/error.log --http-log-path=/var/log/ng...

时序数据流官方模板

本文介绍了时序数据流官方模板。时序数据流模板表示从设备实例或视频数据流实例获取时序数据并执行一系列 SQL 语句,然后将处理结果推送到虚拟时序设备或 Kafka 服务器。基本信息您可以在边缘智能控制台的官方模板... Kafka输出 kafka-brokers String 是设置 Kafka 服务器的访问地址(包含端口号)。 topic String 是设置消息的主题。 sasl-auth String 否选择 Kafka 服务器启用的 SASL 认证的类型。取值: none pla...

数据结构

false BuiltinKafkaSettings在 EndpointType 取值为 Builtin_Kafka 时,目标库的信息。被以下接口引用: DataSource 参数类型是否必选描述示例值 Brokers Array of String 是 Broker 的 IP 地址及端口号,格... 取值如下: Error:表示在预检查项的等级为若不通过则预检查不通过。 Warning:若不通过则不影响整个预检查是否通过。 Error Name String 检查项的名称。运行环境检测 Desc String 检查项的描述。运行环境检测 ...

【GMP3.11】Webhook通道接入

但是是基于流水号/消息ID的单个查询支持批量发送与批量响应支持kafka/rmq的发送与接收如何判断gmpWebhook是否可以承载客户业务? gmpWebhook本质是通过产品化配置直接构造http请求访问客户接口,因此需要客户接口请... 算法aes/gcm/noPadding/base64需要设置盐值,通过该参数传入 dataConverter 用于做数据格式转换,目前支持json和urlEncoded之间的相互转换使用场景:客户系统的请求响应数据可能都是urlEncoded格式的,但gmp只能输出/...