Micronaut Kafka健康检查报Cluster authorization failed错误如何处理

该报错是Kafka健康检查依赖的AdminClient无法通过集群权限校验导致的。你能正常消费消息说明消费者的权限配置正常，但AdminClient没有拿到正确的安全认证参数，或者当前账号没有AdminClient调用接口所需的集群权限。

• 补全AdminClient的安全配置
  大部分微服务框架的Kafka健康检查会单独初始化AdminClient实例，需要显式给AdminClient配置和消费者一致的SASL_SSL、认证信息，你可以在application.yaml中添加如下配置：

  kafka:
    admin:
      security.protocol: "SASL_SSL"
      sasl:
        mechanism: "SCRAM-SHA-512"
        jaas:
          config: org.apache.kafka.common.security.scram.ScramLoginModule required username="${KAFKA_USERNAME:username}" password="${KAFKA_PASSWORD:password}";
  

• 给账号分配集群DESCRIBE权限
  如果配置已经正确，说明你当前使用的Kafka账号没有集群层面的DESCRIBE权限，AdminClient做健康检查默认会调用describeCluster()接口拉取集群元数据，需要联系Kafka集群管理员给你的账号开通该权限，参考授权命令如下：
  kafka-acls.sh --bootstrap-server bootstrap.example.com:9095 --command-config admin.properties --add --allow-principal User:${KAFKA_USERNAME} --operation Describe --cluster

• 调整健康检查逻辑
  如果不想开通额外权限，也可以修改健康检查的默认行为：

  1. 直接关闭Kafka健康检查，避免影响服务整体健康状态
  2. 将健康检查的校验对象从集群改为你当前已经有权限消费的Topic，比如Micronaut框架可以配置kafka.health.topic=你的消费Topic名称，Spring Boot可以自定义健康检查逻辑，仅校验对指定Topic的访问权限即可。

你当前配置中kafka.bootstrap.security.protocol属于冗余配置，可以直接删除，避免不同层级的配置冲突导致异常。

内容的提问来源于stack exchange，提问作者Imre Kerr