Spark Structured Streaming + Kafka使用筆記

這篇博客將會記錄Structured Streaming + Kafka的一些基本使用(Java 版) spark 2.3.0 1. 概述 Structured Streaming （結構化流）是一種基於 Spark SQL 引擎構建的可擴展且容錯的 stream processing engine （流處理引擎）。可以使用Dataset/DataFrame API 來表示 streaming a

>>阅读原文<<