props.put("sasl.kerberos.service.name", "kafka"); 但是,我收到一个错误消息: java.lang.IllegalArgumentException: Couldnot find a 'KafkaClient' entry in the JAASconfiguration.... 53 more
Caused by: java.lang.IllegalArgumentExcept
为此,我必须在optional.configuration中正确地传递用户名/密码。我在@source中传递它(如下图所示),但是得到了错误Could not find a 'KafkaClient' entry in the JAASconfiguration.not find a 'KafkaClient' entry in the JAAS
我将jaas conf放在与jar相同的目录中。configuration not found at org.apache.kafka.common.security.kerberos.KerberosLogin.getServiceNameorg.apache.kafka.common.network.S
java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'sasl_plaintext.KafkaServer' entryin the JAASconfiguration.System property 'java.security.auth.login.config' is /usr/hdp/current/kafka
kafka-connect.properties s3-sink.properties 起初,我得到了以下错误: Caused by: java.lang.IllegalArgumentException: Couldnot find a 'KafkaClient' entry in the JAASconfiguration.System property 'java.security.auth.login.config' is not set
using the broker configuration property sasl.jaas.config.="admin" \问题是,当我启动Kafka时,会出现以下错误:
java.lang.IllegalArgumentException: Couldnot find a 'KafkaServer' or 'plaintext.KafkaServer' entry<
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: java.lang.IllegalArgumentException: Couldnot find a 'KafkaClient' entry in the JAASconfiguration.
我不确定如何通过Flink传递JAAS (java.security.auth.login.config)和其他系统属性。--quiet', 'properties.sasl.mechanism' = 'GSSAPI');
[ERROR] CouldReason:
java.lang.IllegalArgumentException: Could not find a '