kafka_client_jaas.conf配置参数

KafkaClient{

com.sun.security.auth.module.Krb5LoginModule required

useKeyTab=true

renewTicket=true

serviceName="kafka"

keyTab="./xxxx.keytab"

storeKey=true

useTicketCache=false

principal="xxxx@xxx";

}

keyTab配置目录一定要用  ./  不要用 具体目录,否则 下发到每个节点 找不到该文件

spark 参数配置

添加参数   目录 java.security.auth.login.config 下的配置 也不要写 固定目录 用./  表示  否则 下发到每个节点 找不到该文件

--driver-java-options "-Djava.security.auth.login.config=/xxx/kafka_asiainfo_client_jaas.conf" \

--conf "spark.executor.extraJavaOptions=-Djava.security.auth.login.config=./kafka_asiainfo_client_jaas.conf" \

--jars   /data/xxxx/kafka asiainfo client jaas,conf,/data/xxx.keytab,/data/xxxx/krb5.conf

问题1描述:

aused by: java.lang.IllegalArgumentException: could not find a "Kafkaclient' entry in the Jas configuration. system property "java.security.auth.login.config is not set

问题2

aused by: java.lang.securityException: java 10,10Exception: /data/kafka_config/kafka asainfo client jaas.conf (o such file or directory

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐