user_admin="pass";
authorizer.class.name=kafka.security.authorizer.AclAuthorizer
такие настройки прописал, добавил пользака
./kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config 'SCRAM-SHA-256=[password=pass],SCRAM-SHA-512=[password=pass]' --entity-type users --entity-name admin
но сталкиваюсь с ошибкой при запуске кафки, что некорректно настроенО?
java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'internal.KafkaServer' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
попробуй ещё указать security.protocol
вы в listener.security.protocol.map задали имена листнеров, вам ими и надо оперировать в настройках юзеров, вроде как listener.name.internal.scram-sha-256.sasl.jaas.config=.... причем для каждого listener.name.external.scram-sha-256.sasl.jaas.config=....
Обсуждают сегодня