Добрый день. Замучал меня вопрос авторизации на сервере кафка. Подскажите

как правильно сделать?? Пытаюсь хотя бы настроить SASL Plaintext без сертификатов, прописал в конфиге данные, делаю команду експорта но по итогу получаю ошибку java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'sasl_plaintext.KafkaServer' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
Хотя команду делаю export KAFKA_OPTS=-Djava.security.auth.login.config=/usr/local/kafka-server/config/kafka_server_jaas.conf может у кого есть под рукой мануал как правильно сделать защиту для доступа kafk-у. В интернете много, но что не пробовал всё файлидся.

https://inaword.ru/security/kafka-chast-3-prostaya-autentifikatsiya-sasl-metodom-plain-bez-zashhity-kanala-sasl_plaintext/ Я вот по этому настраивался

да спасибо, понял что listeners=PLAINTEXT://localhost:9092,SASL_PLAINTEXT://localhost:9093 без первого плайнтекса почему то не стартует( типо он всегда должен быть, спасибо вроде запустился брокер. Осталось найти код на пайтон с авторизацией, чтоб протестирповать)

https://stackoverflow.com/questions/65729535/how-to-do-i-connect-kafka-python-to-accept-username-and-password-for-jaas-like-i

в данном примепре SECURITY_PROTOCOL = "SASL_SSL" А я не понял, в том что Вы выше скинули, там идёт шифрование или нет?

а, да, сорян. Это не то. Пример был без SSL

тут можно посмотреть https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/sasl_producer.py

а ssl не прикручивал?

На тесте пробовал. Настраивал по этому мануалу, тут прям step-by-step https://www.youtube.com/watch?v=hR_OuiqLgOo&t=81s

спасибо гляну-)