KStream和KTable是Kafka Streams里内建的两个最重要的抽象,分别对应数据流和数据库。Kafka Streams作为流处理技...
KStream和KTable是Kafka Streams里内建的两个最重要的抽象,分别对应数据流和数据库。Kafka Streams作为流处理技...
同为流处理技术,Kafka Streams的API和更为人所熟知的Spark Streaming在很多方面有不少相似之处,比如大量类似的算子。因...
仅仅是一段代码 Kafka Streams作为集成在Kafka系统中的一个API,在配合Kafka来进行流处理时有着得天独厚的优势。不同于Spa...
Docker在很多时候都可以帮助我们快速搭建想要的开发环境,免去了很多安装配置上的麻烦。在涉及到Apache Kafka的快速demo时,使用D...
WordCount WordCount 堪称大数据界的HelloWorld,相信不管是Hadoop还是Spark等大数据工具的上手实例,第一个十...
现在开源流处理框架越来越多,大家都熟知的有 Spark Streaming, NiFi, Flink等等。Kafka Streams 也是其中一...
在搭建数据通道(data pipeline)时,由于涉及到:数据读取,数据分析,数据存储等等,如果将各个部分分别容器化,独立设计各个模块,将有助...
快速语法对照 List HashMap Set For loop Range
Scala中,使用 to*方法 在很多情况下可以方便地进行类型转换。 toString toInt toDouble toFloat toLon...
Kafka Connect 作为service提供了 REST API 服务,用来: 获取 Kafka Connect 状态 管理 Kafka ...
专题公告
大数据,数据工程,数据科学方向的技术点滴。