Ошибка безопасности KAFKA — ошибка SASL PlainText ⇐ C#

[Anonymous]

Я новичок в Kafka, и мне нужно внедрить безопасность SASL PLAINTEXT (имя пользователя/пароль) в брокерах Kafka. я пробовал разные вещи, но до сих пор добился успеха. у меня есть конфигурации, которые я сделал:

• создал файл kafka_server_jaas.conf

KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required

username="admin"

password="admin-secret"

user_admin="admin-secret"

user_client="client-secret";
};

• установите KAFKA_OPTS в переменных среды, но я также сделал это в файле kafka-run-class.bat
  
  установить KAFKA_OPTS в переменных среды, но я также сделал это в файле kafka-run-class.bat
  
  установить KAFKA_OPTS в переменных среды li>

set KAFKA_OPTS="-Djava.security.auth.login.config=C:\kafka\config\kafka_server_jaas.conf"

• Файл server.properties содержит следующие изменения

listeners=SASL_PLAINTEXT://localhost:9092
advertised.listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
authorizer.class.name=kafka.security.authorizer.AclAuthorizer
allow.everyone.if.no.acl.found=true
auto-create-topics-enable=true

zookeeper работает нормально, но когда я выполняю команду ниже для запуска сервера Kafka
.\bin\windows\kafka-server-start.bat .\config\server.properties

Я получил ошибку ниже
Error connecting to node localhost:9092

java.io.IOException: Channel could not be created for socket java.nio.channels.SocketChannel[closed]

Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.errors.SaslAuthenticationException: Failed to configure SaslClientAuthenticator


Подробнее здесь: https://stackoverflow.com/questions/791 ... text-error