文档首页/ MapReduce服务 MRS/ 故障排除/ 使用Spark/ Spark连接Kafka认证错误
更新时间:2023-11-10 GMT+08:00

Spark连接Kafka认证错误

问题现象

MRS 2.1.0版本集群中Spark消费kafka数据,过一天以后就会出现认证失败的报错:

原因分析

集群版本和运行的程序包版本不匹配。

处理步骤

  1. 参考运行Spark Streaming 对接Kafka0-10样例程序进行相关配置。
  2. 当前集群为MRS 2.1.0版本,请如需使用Maven库中的提供的样例程序,请获取spark-streaming-kafka-0-10_2.11-2.3.2-mrs-2.1.jar包。