添加kafka 后报如下错误我又添加了kafka-clients-0.9.0.0.jar 然后报错

来源：10-7 -Receiver方式整合之服务器环境联调及Streaming UI讲解

啊大bug

2020-12-31

图片描述

spark-submit
–class com.imooc.spark.KafkaReceiverWordCount
–master local[2]
–name KafkaReceiverWordCount
–jars /root/zhangm/maven_repos/org/apache/spark/spark-streaming-kafka-0-8_2.11/2.2.0/spark-streaming-kafka-0-8_2.11-2.2.0.jar,/root/zhangm/maven_repos/org/apache/kafka/kafka_2.11/0.9.0.0/kafka_2.11-0.9.0.0.jar,/root/zhangm/maven_repos/org/apache/kafka/kafka-clients/0.9.0.0/kafka-clients-0.9.0.0.jar
/root/zhangm/jars/sparktrain-1.0.jar itcast01:2181 test kafka_streaming_topic 1

写回答

1回答