FAQ-Kafka开启acl权限控制

更新时间: 2024-03-11 02:49:59 | 阅读 1870

扫码

复制

导出

问题描述

问题描述

问题描述/异常栈

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

解决方案

1）任务配置页面-生产者配置：
key：security.protocol  value：SASL_PLAINTEXT
key：sasl.mechanism value：PLAIN
2）将文件上传到azkaban的资源文件
3）节点属性添加配置
key:ndi.spark.spark-argument.files，value:文件
key: ndi.spark.spark-conf.spark.executor.extraJavaOptions，value: "-Djava.security.auth.login.config=文件"