Apache Samza

Apache Samza

Apache Samza:分布式流处理框架Apache Samza 帮助开发者构建有状态的实时数据处理应用,支持从 Apache Kafka 等多个来源读取数据,并以高吞吐、低延迟方式进行处理。框架支持 YARN、Kubernetes 或独立库部署,并提供多种 API 与可插拔连接器。

Apache Samza 页面快照
4
应用开发 API:低级 API、Streams DSL、Samza SQL 与 Apache Beam
3
部署方式:YARN、Kubernetes 与独立库
实时
面向多数据源的流式数据处理模式
核心能力

为实时数据应用提供灵活的处理能力

从流式计算、状态管理到部署和数据连接,Apache Samza 提供构建与运行实时处理应用所需的基础能力。

高性能流处理

提供极低延迟和高吞吐能力,支持对实时数据进行即时分析。

水平扩展

支持处理数 TB 规模的状态,并通过增量检查点和主机亲和性增强扩展能力。

灵活部署

可部署在 YARN、Kubernetes 或独立库环境中,适应不同运行方式。

多种开发 API

提供低级 API、Streams DSL、Samza SQL 和 Apache Beam API,用于构建实时数据应用。

批流统一处理

支持使用同一套代码处理批处理数据和流式数据。

可插拔数据连接

可连接 Apache Kafka、HDFS、AWS Kinesis、Azure Event Hubs、键值存储和 Elasticsearch 等数据源或存储。

项目动态

Apache Samza 发布记录

以下内容来自 Apache Samza 官方博客中的公开发布公告。

Announcing the release of Apache Samza 1.8.0

Apache Samza 官方博客发布 1.8.0 版本公告。

Announcing the release of Apache Samza 1.6.0

Apache Samza 官方博客发布 1.6.0 版本公告。

Announcing the release of Apache Samza 1.5.1

Apache Samza 官方博客发布 1.5.1 版本公告。

官方资料

从文档、示例与案例开始

通过快速开始、核心概念文档、下载入口和案例研究了解 Apache Samza 的使用方式与应用场景。

Apache Samza

从这里开始使用Apache Samza。