我正在使用Apache kafka版本2。我正在尝试使用用户名和密码(SASL_PLAINTEXT)来实现对Kafka的身份验证,并遵循下面的链接来实现相同的身份验证。 https://developer.ibm.com/hadoop/2017/04/10/kafka-security-mechanism-saslplain/ 我已经根据上面的url更改了配置。但是我的误差越来越小了。 java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'sasl_plaintext.KafkaS
我正在尝试对KafkaConsumer使用kerberos身份验证。 为此,我添加了以下属性。 props.put("security.protocol", "SASL_PLAINTEXT"); // Setting this means we try to look in jaas.conf
props.put("sasl.kerberos.service.name", "kafka"); 但是,我收到一个错误消息: java.lang.IllegalArgumentException: Could not f
我正在做一个siddhi应用程序,在那里我必须连接到融合卡夫卡服务器。为此,我必须在optional.configuration中正确地传递用户名/密码。我在@source中传递它(如下图所示),但是得到了错误Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
代码:
@source(type='kafka',
topic.list=&
我正在尝试使用SASL Plain将Kafka Java客户端连接到Kafka broker。但是当我尝试从生产者发送消息时,Kafka服务器记录了以下错误: [2020-04-30 14:48:14,955] INFO [SocketServer brokerId=0] Failed authentication with /127.0.0.1 (Unexpected Kafka request of type METADATA during SASL handshake.) (org.apache.kafka.common.network.Selector) 根据外观,生产者尝试在SAS
我想要做的是- For Clients to Broker communication - use OAUTHBEARER authentication
For Broker to Broker communication - use PLAIN authentication 我有以下JAAS配置: {
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="inter"
password="inter-secret
我遇到了一个非常奇怪的问题
Could not find a "KafkaClient" entry in the JAAS configuration. System property "java.security.auth.login.config" is /etc/kafka/kafka_sink_jaas.conf
在单节点Apache Flink集群上,当我使用Apache Beam KafkaIO消费来自kafka的记录时。JAAS文件包含“KafkaClient”,但Flink群集找不到该条目。有没有人知道原因?
我们正在尝试使用带有JAAS的独立java客户端来使用WAFFLE for SSO。我们在jaas.conf中提到了waffle.jaas.WindowsLoginModule,但它提示输入用户名和密码,我们认为这不是单点登录的理想解决方案。有没有人能建议如何避免这种情况?
仅供参考-我们没有使用任何web/应用服务器。
我有一个用于wurstmeister/kafka的基本文件
我试图将它配置为与SSL一起使用SASL_PLAIN,但是无论我试图指定jaas文件的方式有多少种,我仍然会得到这个错误。
这就是我所犯的错误
[2018-04-11 10:34:34,545] FATAL [KafkaServer id=1001] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.IllegalArgumentException: Could not find a '