Spark Streaming 寫kafka報錯:kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

最近有個spark 讀寫kafka任務,直接在idea 以local模式運行沒有問題,可以放到集羣卻報錯 報錯:kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Brokera 然後百度查了下,說是spark與kafka版本問題衝突。查看了下集羣spark1.6,kafka只找到了kafka_2.10-0.9.0-kafka-
相關文章
相關標籤/搜索