Micronaut Kafka：运行状况检查失败并显示“集群授权失败”答案

【问题标题】：Micronaut Kafka: Health check fails with "Cluster authorization failed"Micronaut Kafka：运行状况检查失败并显示“集群授权失败”
【发布时间】：2021-09-06 07:01:36
【问题描述】：

我正在尝试使用来自我组织外部的 Kafka 集群的消息，这需要身份验证。

我正在接收消息，所以可能部分正确，但我在日志中收到此错误消息：

08:54:50.840 [kafka-admin-client-thread | adminclient-1] ERROR i.m.m.health.indicator.HealthResult - 健康指标 [kafka] 报告异常：org.apache.kafka.common.errors.ClusterAuthorizationException：集群授权失败。

健康检查中的结果状态为DOWN。

这是来自application.yaml的kafka部分：

kafka:
  bootstrap:
    servers:
      "bootstrap.example.com:9095"
    security:
      protocol: "SASL_SSL"
  schema.registry.url: "http://schema-registry.example.com:8001"
  consumers:
    example-group:
      key:
        deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
      value:
        deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
  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}";

【问题讨论】：

标签： apache-kafka micronaut sasl micronaut-kafka

【解决方案1】：

我想通了，“授权”这个词应该是一个很大的提示。

身份验证机制没有任何问题。相反，我们的用户根本没有权限进行所需的调用。

所需的权限是：

描述集群
在资源 BROKER 上描述配置。

【讨论】：

【解决方案2】：

默认情况下，DescribeCluster 还提供有关主题 ACL 的信息，这可能是一个安全问题 :-) 也许您需要自定义的健康检查指标？

【讨论】：