高性能流处理
提供极低延迟和高吞吐能力,支持对实时数据进行即时分析。
Apache Samza
Apache Samza:分布式流处理框架Apache Samza 帮助开发者构建有状态的实时数据处理应用,支持从 Apache Kafka 等多个来源读取数据,并以高吞吐、低延迟方式进行处理。框架支持 YARN、Kubernetes 或独立库部署,并提供多种 API 与可插拔连接器。
从流式计算、状态管理到部署和数据连接,Apache Samza 提供构建与运行实时处理应用所需的基础能力。
提供极低延迟和高吞吐能力,支持对实时数据进行即时分析。
支持处理数 TB 规模的状态,并通过增量检查点和主机亲和性增强扩展能力。
可部署在 YARN、Kubernetes 或独立库环境中,适应不同运行方式。
提供低级 API、Streams DSL、Samza SQL 和 Apache Beam API,用于构建实时数据应用。
支持使用同一套代码处理批处理数据和流式数据。
可连接 Apache Kafka、HDFS、AWS Kinesis、Azure Event Hubs、键值存储和 Elasticsearch 等数据源或存储。
以下内容来自 Apache Samza 官方博客中的公开发布公告。
Apache Samza 官方博客发布 1.8.0 版本公告。
Apache Samza 官方博客发布 1.6.0 版本公告。
Apache Samza 官方博客发布 1.5.1 版本公告。
通过快速开始、核心概念文档、下载入口和案例研究了解 Apache Samza 的使用方式与应用场景。