我正在尝试使用来自我组织外部的 Kafka 集群的消息,这需要身份验证。
我正在接收消息,所以可能部分正确,但我在日志中收到以下错误消息:
08:54:50.840 [kafka-admin-client-thread | adminclient-1] 错误 immhealth.indicator.HealthResult - 健康指标 [kafka] 报告异常:org.apache.kafka.common.errors.ClusterAuthorizationException:集群授权失败。
DOWN
以及健康检查中的结果状态。
这是来自的kafka部分application.yaml
:
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}";