向kafka broker添加SASL _明文身份验证时出现Java . lang . illegalargumentexception

Question

我正在尝试将SASL_PLAINTEXT身份验证配置为kafka代理，下面是我的配置。

advertised.listeners=SASL_PLAINTEXT://127.0.0.1:9092
listeners=SASL_PLAINTEXT://127.0.0.1:9092

security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
sasl.jaas.config=/var/lib/kafka/config/kafka_jaas.conf

在开始动物园管理员和Kafka之后，我得到了以下例外

kafka.Kafka.main：要求失败：Kafka.scala必须是在advertised.listeners.中定义的侦听器名称基于当前配置的侦听器的有效选项是PLAINTEXTjava.lang.IllegalArgumentException：要求失败：inter.broker.listener.name必须是在advertised.listeners.中定义的侦听器名称基于当前配置的侦听器的有效选项是PLAINTEXT在scala.Predef$.要求（Predef.scala:233）在kafka.server.KafkaConfig.validateValues（KafkaConfig.scala:1089）在kafka.server.KafkaConfig.（KafkaConfig.scala:1065）在kafka.server.KafkaConfig$. fromProps（KafkaConfig.scala:795）在kafka.server.KafkaConfig$. fromProps（KafkaConfig.scala:792）在kafka.server.KafkaServerStartable$. fromProps（KafkaServerStartable.scala:28）在kafka.Kafka$. main（Kafka.scala:58）在java.lang.IllegalArgumentException（inter.broker.listener.name）

Answer 1

我在Kubernetes上设置kafka_listeners时遇到了类似的问题。以下是一个有效的kafka配置yaml片段：

    env:
    ...
   - name: ALLOW_PLAINTEXT_LISTENER
     value: “yes”
   - name: KAFKA_LISTENER_SECURITY_PROTOCOL_MAP
     value: INSIDE:PLAINTEXT
   - name: KAFKA_LISTENERS
     value: INSIDE://0.0.0.0:9092
   - name: KAFKA_ADVERTISED_LISTENERS
     value: INSIDE://localhost:9092
   - name: KAFKA_INTER_BROKER_LISTENER_NAME
     value: INSIDE

这里讨论的类似问题与 ssl 配置：无法找出具有 ssl 的 kafka 中代理间侦听器名称的设置

这个合流页面也会很有帮助。