为什么Kafka如此需要jaas文件?

1l5u6lss  于 2021-08-25  发布在  Java
关注(0)|答案(0)|浏览(179)

我正在用多个侦听器设置Kafka安全性。代理侦听器作为明文工作,我不想对它们使用身份验证。我的群集具有以下配置:

listeners=BROKERS://:9091,CLIENTS://:9092,CLIENTS-NOSSL://:9093
inter.broker.listener.name=BROKERS
sasl.enabled.mechanisms=SCRAM-SHA-256
listener.security.protocol.map=BROKERS:PLAINTEXT,CLIENTS:SASL_SSL,CLIENTS-NOSSL:SASL_PLAINTEXT

对于客户,我希望使用紧急停堆,并且只针对他们(不针对经纪人)。但当我启动broker时,我在日志中看到以下消息:

ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'clients.KafkaServer' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set

如果我不使用代理身份验证和紧急停堆机制将凭据存储在zookeeper中,为什么需要这个文件?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题