Kafka服务器-在JAAS中找不到“Kafka服务器”

Question

我有一个独立的Kafka经纪人，我试图配置SASL。配置如下。我试图在经纪人身上设置SASL_PLAIN身份验证。

我的理解是，这与听众有关。名称服务器中的配置。属性，我不需要jaas文件。但我已经尝试过一种方法，看看这是否是一种更好的方法。

我对这些命令中的每一个都进行了实验，但都产生了相同的异常。

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

显示的异常为：

KafkaServer启动期间出现致命错误。准备关机。。。找不到“KafkaServer”或“sasl_明文”。JAAS配置中的KafkaServer条目。系统属性的java。安全auth。登录。未设置“配置”

server.properties：

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。形态：

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

我已经花了一天时间研究这个问题——还有人有这个问题的经验吗？

Answer 1

把我的紧缩错误放在这里：

• 不要从cli执行启动命令，请将它们放在命令行中。sh文件并从那里运行：例如，类似以下内容：

zkstart

export KAFKA_OPTS="-Djava.security.auth.login.config=etc/kafka/zookeeper_jaas.conf"
bin/zookeeper-server-start etc/kafka/zookeeper.properties &

Kafka斯塔特

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

• 如果您仍然遇到与配置相关的错误，请检查您的_jaas文件，以确保错误消息中的所有配置部分都存在。如果是，很可能格式不太正确——检查每个部分中的两个分号，如果失败了，试着从头开始（或者从c

因此，我的最终解决方案是添加导出。。。。行到相应kafka服务器开始和zookeeper服务器开始文件的开头。我花了一段时间才最终点击“一切都是文件”，我意识到脚本文件是服务的实际基础。

Answer 2

您需要导出一个变量，而不是将配置内联到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

裁判。合流关于Kafka安全的章节