使用SparkStreaming 读取kafka数据进行处理，程序启动报异常： java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker 原因是kafka client版本和  spark-streaming-kafka 版本不匹配造成的。 pom文件改成