kafka JAR 包冲突

来源：10-9 -Direct方式整合之Spark Streaming应用开发及本地环境测试

qq_张奇_1

2018-05-18

老师， org.apache.kafka： kafka_2.11 和 org.apache.spark ：spark-streaming-kafka-0-8_2.11 这两个依赖是不是互相冲突，同时引入这两个依赖，KafkaUtils.createDirectStream这个方法会报错，去掉org.apache.kafka： kafka_2.11 就好了，但有没有这两个依赖同时引用的可能，比如说我同一个项目既要kafka整合spark，同时这个项目又要用到kafka 原生的API（不知道我的表达和理解有没有问题）

写回答

4回答

Michael_PK

2018-05-18

已采纳

明白你的意思，我感觉直接用streaming kafka那一个依赖可能就可以了，你尝试下

lamarsan

2019-01-25

我把Kafka的jar包去掉就好了，不然会冲突，报这个错误：Exception in thread "main" java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Michael_PK

是的，直接用streaming kafka的依赖就成了

2019-01-25

共1条回复