该错误的原因是在 kafka-0-10 版本后 接口发生了变化 官方修改为:kafka010,就是说在原来的基础上需要在kafka后面添加010即可例如:
参考的官方文档链接是:http://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html
该错误的原因是在 kafka-0-10 版本后 接口发生了变化 官方修改为:kafka010,就是说在原来的基础上需要在kafka后面添加010即可例如:
参考的官方文档链接是:http://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html