文章预览
作者| 郭俊 编辑|江柳 Kafka Stream 背景 Kafka Stream 是什么 Kafka Stream 是 Apache Kafka 从 0.10 版本引入的一个新 Feature。它是提供了对存储于 Kafka 内的数据进行流式处理和分析的功能。 Kafka Stream 的特点如下: Kafka Stream 提供了一个非常简单而轻量的 Library,它可以非常方便地嵌入任意 Java 应用中,也可以任意方式打包和部署 除了 Kafka 外,无任何外部依赖 充分利用 Kafka 分区机制实现水平扩展和顺序性保证 通过可容错的 state store 实现高效的状态操作(如 windowed join 和 aggregation) 支持正好一次处理语义 提供记录级的处理能力,从而实现毫秒级的低延迟 支持基于事件时间的窗口操作,并且可处理晚到的数据(late arrival of records) 同时提供底层的处理原语 Processor(类似于
………………………………