You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Kafka Schema Registry返回401未授权错误,producer.send发送记录失败

Kafka带Schema生产记录未授权问题排查项
  • Schema Registry侧权限遗漏配置:多数用户仅为业务Kafka主题分配了权限,忽略了Schema Registry本身的权限管控。需确认当前认证账号对目标Schema对应的Subject有WRITE权限,首次写入新Schema时还需要SCHEMA_CREATE权限,权限管控严格的集群还需开放Subject的创建/修改权限。
  • Schema Registry独立认证未配置:Kafka Producer的集群认证和Schema Registry的认证是两套独立配置,仅配置基础认证信息到Kafka客户端不会自动传递给Schema Registry,需额外添加以下配置:
    schema.registry.basic.auth.credentials.source=USER_INFO
    schema.registry.basic.auth.user.info=<你的账号>:<你的密码>
    若Schema Registry采用SASL认证,还需额外补充对应的SASL相关配置项。
  • _schemas内部主题权限缺失:Confluent Schema Registry默认会将所有Schema持久化存储到Kafka内置的_schemas主题中,若当前账号没有该主题的读写权限,首次注册Schema时也会抛出未授权错误,和业务主题的权限配置无关。
  • Broker侧Schema校验权限异常:若集群开启了Broker端的Schema合法性校验,Broker本身需要有访问Schema Registry拉取Schema的权限,若Broker侧权限缺失,也会向生产者返回未授权错误。
  • 认证参数作用域配置错误:检查security.protocol、sasl.jaas.config、ssl.endpoint.identification.algorithm等认证相关参数是否和集群要求一致,部分托管Kafka集群要求必须配置security.protocol=SASL_SSL才会正常传递认证凭证。

内容的提问来源于stack exchange,提问作者Geeky

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.10.06 16:06:04