时间戳

首页 > 解决方案 > Kafka - 在 JAAS 配置中找不到“KafkaClient”条目

java - Kafka - 在 JAAS 配置中找不到“KafkaClient”条目

问题描述

用例：尝试集成Kafka和Druid，通过KafkaClient将数据从Kafka加载到Druid。

当我们尝试相同时，我们正面临着这个问题。请找到详细信息并帮助我解决相同的问题。

问题：

Caused by: org.apache.kafka.common.KafkaException: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
        at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:94) ~[?:?]
        at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:93) ~[?:?]
        at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:51) ~[?:?]
        at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:84) ~[?:?]
        at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:657) ~[?:?]
        ... 10 more
Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set

JAAS 配置文件： 

KafkaClient {
       com.sun.security.auth.module.Krb5LoginModule required
       useKeyTab=true
       keyTab="/hadoop_shared/net/bdnetflow.headless.keytab"
       debug=true
       storeKey=true
       useTicketCache=false
       serviceName="kafka"
       principal="bdnetflow@HDP_PRD.COX.COM";
};
Client {
       com.sun.security.auth.module.Krb5LoginModule required
       useKeyTab=true
       keyTab="/hadoop_shared/net/bdnetflow.headless.keytab"
       debug=true
       storeKey=true
       useTicketCache=false
       serviceName="kafka"
       principal="bdnetflow@HDP_PRD.COX.COM";
};

标签： javaapache-kafkadruid

解决方案

推荐阅读