Kafka“未在JAAS配置中指定登录模块”

有两种方法可以向Kafka客户端提供JAAS配置。

• 通过客户端属性：

  sasl.jaas.config

  。在这种情况下，将其设置为实际的JAAS配置条目。例如，您的配置文件变为：

        bootstrap.servers=(address)    zookeeper.connect=127.0.0.1:2181    zookeeper.connection.timeout.ms=6000    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="(username)" password="(password)";    security.protocol=SASL_PLAINTEXT    sasl.mechanism=PLAIN    group.id=(group)

如您所知，您可以

--command-config

kafka-consumer-groups.sh

• 通过Java属性：

  java.security.auth.login.config

  。在这种情况下，将其设置为JAAS文件的路径。另外，如果您将其设置为

  KAFKA_OPTS

  ，

  kafka-consumer-groups.sh

  则会自动将其拾取。

  export KAFKA_OPTS="-Djava.security.auth.login.config=(path)/consumer_jaas.conf"