KStream和KTable是Kafka Streams里內(nèi)建的兩個最重要的抽象,分別對應(yīng)數(shù)據(jù)流和數(shù)據(jù)庫。Kafka Streams作為流處理技...
同為流處理技術(shù),Kafka Streams的API和更為人所熟知的Spark Streaming在很多方面有不少相似之處,比如大量類似的算子。因...
僅僅是一段代碼 Kafka Streams作為集成在Kafka系統(tǒng)中的一個API,在配合Kafka來進(jìn)行流處理時有著得天獨(dú)厚的優(yōu)勢。不同于Spa...
Docker在很多時候都可以幫助我們快速搭建想要的開發(fā)環(huán)境,免去了很多安裝配置上的麻煩。在涉及到Apache Kafka的快速demo時,使用D...
WordCount WordCount 堪稱大數(shù)據(jù)界的HelloWorld,相信不管是Hadoop還是Spark等大數(shù)據(jù)工具的上手實例,第一個十...
現(xiàn)在開源流處理框架越來越多,大家都熟知的有 Spark Streaming, NiFi, Flink等等。Kafka Streams 也是其中一...
在搭建數(shù)據(jù)通道(data pipeline)時,由于涉及到:數(shù)據(jù)讀取,數(shù)據(jù)分析,數(shù)據(jù)存儲等等,如果將各個部分分別容器化,獨(dú)立設(shè)計各個模塊,將有助...
快速語法對照 List HashMap Set For loop Range
Scala中,使用 to*方法 在很多情況下可以方便地進(jìn)行類型轉(zhuǎn)換。 toString toInt toDouble toFloat toLon...