如何从Kafka CLI访问SASL配置Kafka

问题描述

我有一个配置了Kafka的SASL PLAIN，但无法使用cli连接到它，并且文档尚不清楚。下面是我到目前为止使用的命令。

bin/kafka-topics.sh --list --bootstrap-server localhost:9093

任何帮助将不胜感激。

解决方法

Kafka文档中有一节详细介绍了使用SASL Plain连接到集群所需的配置：https://kafka.apache.org/documentation/#security_sasl_plain_clientconfig

它列出了以下设置：

security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
        username="alice" \
        password="alice-secret";

很明显，这取决于SSL配置，您可能需要添加一些额外的设置，请参见https://kafka.apache.org/documentation/#security_configclients

将所有这些设置放入文件中，然后在使用--command-config时可以使用kafka-topics.sh指定此文件。例如：

bin/kafka-topics.sh --list --bootstrap-server localhost:9093 --command-config /path/to/file.properties

apache-kafka sasl