Spark 从2.3 起不再支持 Kafka0.8.2,EMR 现网版本已集成 Spark2.4.3及以上版本,需要集成 kafka 0.10.0及更高版本。
https://spark.apache.org/docs/{spark.version}/streaming-kafka-integration.html
将 {spark.version}
替换为对应的 Spark 版本。例如查看3.2.2版本的依赖关系,访问链接如下:
https://spark.apache.org/docs/3.2.2/streaming-kafka-integration.html
本页内容是否解决了您的问题?