apache-kafka - Kafka 服务器 - 在 JAAS 中找不到 'KafkaServer'

Question

我有一个独立的 kafka 代理，我正在尝试为其配置 SASL。配置如下。我正在尝试在代理上设置 SASL_PLAIN 身份验证。

我的理解是，通过 server.properties 中的 listener.name... 配置，我不需要 jaas 文件。但我已经尝试过一种方法，看看这是否是更好的方法。

我已经尝试了这些命令中的每一个，但都导致了相同的异常。

• sudo bin/kafka-server-start etc/kafka/server.properties
• sudo -Djava.security.auth.login.config=etc/kafka/kafka_server_jaas.conf bin/kafka-server-start etc/kafka/server.properties

显示的异常是:

Fatal error during KafkaServer startup. Prepare to shutdown... Could not find a 'KafkaServer' or 'sasl_plaintext.KafkaServer' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set

服务器属性:

listeners=SASL_PLAINTEXT://0.0.0.0:9092
listener.security.protocol.map: SASL_PLAINTEXT:SASL_PLAINTEXT
listener.name.SASL_PLAINTEXT.plain.sasl.jaas.config:
            org.apache.kafka.common.security.plain.PlainLoginModule required /
username="username" /
password="Password" /
user_username="Password";  

advertised.listeners=SASL_PLAINTEXT://[ipaddress]:9092
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
secutiy.inter.broker.protocol=SASL_PLAINTEXT

kafka_server_jaas.conf:

KafkaServer {
  org.apache.kafka.common.security.plain.PlainLoginModule required
   username="username"
   password="Password"
   user_username="Password";
};

我已经花了一天时间研究这个问题 - 有没有其他人遇到过这个问题？

Answer 1

您需要导出一个变量，而不是将配置内联到 kafka-server-start(或 sudo)。

export KAFKA_OPTS="-Djava.security.auth.login.config=/path/to/kafka_server_jaas.conf"
bin/kafka-server-start /path/to/server.properties

引用。 Confluent's sections on Kafka security