文档首页> MapReduce服务 MRS> 组件操作指南> 使用Hudi> Hudi常见问题> 数据采集> 使用kafka采集数据时报错IllegalArgumentException
更新时间:2022-05-11 GMT+08:00
分享

使用kafka采集数据时报错IllegalArgumentException

问题

线程“main”报错 org.apache.kafka.common.KafkaException,构造kafka消费者失败,报错:

java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set

回答

当试图从启用SSL的kafka数据源采集数据时,而安装程序无法读取jars.conf文件及其属性时,可能会发生这种情况。

要解决此问题,需要将所需的属性作为通过Spark提交的命令的一部分传递。如:--files jaas.conf,failed_tables.json --conf 'spark.driver.extraJavaOptions=-Djava.security.auth.login.config=jaas.conf' --conf 'spark.executor .extraJavaOptions=-Djava.security.auth.login.config=jaas.conf'

分享:

    相关文档

    相关产品

关闭导读