使用SparkStreaming报错java.lang.ClassNotFoundException: org.apache.spark.internal.Logging$class解决方案

在使用sparkStreaming从kafka中采集数据报java.lang.ClassNotFoundException: org.apache.spark.internal.Logging$class错误：


我的pom.xml部分依赖如下：

解决方案

错误原因大概就是，spark的jar包版本过高，不提供org.apache.spark.internal.Logging这个类，因此，将依赖更换如下：

问题解决。