Kafka Streams:未在JAAS配置中指定登录模块控制标志

Question

我正在尝试使用Java运行我的Kafka Streams应用程序，并以K，V对的形式将合流凭证作为环境变量传递。

但是我面临着一个错误的问题-

- org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient 
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
Caused by: java.lang.IllegalArgumentException: Login module control flag not specified in JAAS config

下面是我如何设置Kafka属性的-

Properties kafkaProps = new Properties();
kafkaProps.put(StreamsConfig.APPLICATION_ID_CONFIG, "MyKafkaApplicationV1.0.0");
kafkaProps.put(StreamsConfig.STATE_DIR_CONFIG, "tmp/state-store");
kafkaProps.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, System.getenv("bootstarpServers"));
kafkaProps.put(StreamsConfig.SECURITY_PROTOCOL_CONFIG, System.getenv("securityProtocol"));

kafkaProps.put(SaslConfigs.SASL_JAAS_CONFIG, System.getenv(SASL_JAAS_CONFIG));
kafkaProps.put(SaslConfigs.SASL_MECHANISM, System.getenv(SASL_MECHANISM));

下面是我如何传递环境变量的-

export saslJaasConfig=org.apache.kafka.common.security.plain.PlainLoginModule required username='MyUserName' password='MyPassword';
export saslMechanism=PLAIN

但是如果我直接在properties对象中硬编码Creds字符串，比如-kafkaProps。put（SaslConfigs.SASL_JAAS_CONFIG，“org.apache.kafka.common.security.plain.PlainLoginModule所需用户名='MyUserName'password='MyPassword'；” 然后它工作并且没有显示错误。

请帮助我错过了什么！！提前感谢。




Answer 1

您可以将jass配置作为jvm参数传递。请试试这个。

-djava.security.auth.login.config=jaas_config.conf

jaas_config.conf内容

KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="username"
    password="password";
 };