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

Question

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

Answer 1

提问者 啊大bug 2020-12-31 00:29:16

pk 哥 我晓得了 报啥错肯定是缺包  添加就行了  哈哈

• Michael_PK #1

  说的太对了，在工作中也经常遇到的，缺啥包就加啥包