深入浅出Spark实时处理（三）--- Structured Streaming集成Kafka
Kafka 0.10的 Structured Streaming 集成，可从Kafka读取数据或向Kafka写入数据。 从Kafka读取数据 def run(): Unit ={val df = spark.readStream.format("kafka").option("kafka.bootstrap.servers", "...
