Apache Samza logo

Apache Samza

Apache Samza is a distributed stream processing framework that provides a simple API for building stateful stream processing applications. It integrates with Apache Kafka for messaging and supports both stream and batch processing.

1 APIs 3 Capabilities 6 Features 42.1 / 100 thin
Big DataHadoopKafkaStream ProcessingStreamingApacheOpen Source

API Rating

42.1/ 100
thin
Scored 2026-05-20 · rubric v0.3
Discoverability80.0
Contract Quality59.8
Governance39.5
Operational Transparency36.8
Developer Ergonomics8.7
Commercial Clarity39.5

APIs

Apache Samza

Samza provides a high-level Streams API and low-level Task API in Java/Scala for stateful stream processing, with a REST API for job management and integration with Kafka, HDFS,...

Capabilities

Apache Samza REST API — Checkpoints

Apache Samza REST API — Checkpoints. 1 operations. Lead operation: Apache Samza Get Checkpoints. Self-contained Naftiko capability covering one Apache Samza business surface.

Run with Naftiko

Apache Samza REST API — Jobs

Apache Samza REST API — Jobs. 4 operations. Lead operation: Apache Samza List Jobs. Self-contained Naftiko capability covering one Apache Samza business surface.

Run with Naftiko

Apache Samza REST API — Tasks

Apache Samza REST API — Tasks. 1 operations. Lead operation: Apache Samza List Tasks. Self-contained Naftiko capability covering one Apache Samza business surface.

Run with Naftiko

Features

Kafka Integration

Native Apache Kafka consumer/producer for stream processing

YARN Execution

Runs on Apache YARN for resource management and fault tolerance

Stateful Processing

Local state stores with RocksDB for low-latency stateful computations

Exactly-Once Processing

Transactional state stores for exactly-once semantics

Flexible Deployment

Run on YARN, Kubernetes, or standalone

High Level API

Fluent API and SQL support for stream transformations

Use Cases

Event Stream Processing

Real-time processing of Kafka event streams

Stateful Aggregations

Windowed aggregations over streaming data

Stream Joins

Join multiple Kafka streams for enrichment

Change Data Capture

Process CDC events from databases in real time

Integrations

Apache Kafka

Primary messaging system for Samza input and output streams

Apache YARN

Resource management and job scheduling on Hadoop

Apache Hadoop

HDFS integration for checkpoint storage

RocksDB

Embedded state store for local stateful processing

Semantic Vocabularies

Apache Samza Context

8 classes · 17 properties

JSON-LD

API Governance Rules

Apache Samza API Rules

6 rules · 4 errors 2 warnings

SPECTRAL

Resources

👥
GitHubOrganization
GitHubOrganization
🔗
Documentation
Documentation
🔗
SpectralRules
SpectralRules
🔗
Vocabulary
Vocabulary
🔗
JSONLD
JSONLD

Sources

Raw ↑ 
aid: apache-samza
name: Apache Samza
description: Apache Samza is a distributed stream processing framework that provides a simple API for building stateful stream
  processing applications. It integrates with Apache Kafka for messaging and supports both stream and batch processing.
type: Index
position: Consumer
access: 3rd-Party
image: https://kinlane-productions2.s3.amazonaws.com/apis-json/apis-json-logo.jpg
tags:
- Big Data
- Hadoop
- Kafka
- Stream Processing
- Streaming
- Apache
- Open Source
created: '2026-03-16'
modified: '2026-05-19'
url: https://raw.githubusercontent.com/api-evangelist/apache-samza/refs/heads/main/apis.yml
specificationVersion: '0.19'
apis:
- aid: apache-samza:apache-samza
  name: Apache Samza
  description: Samza provides a high-level Streams API and low-level Task API in Java/Scala for stateful stream processing,
    with a REST API for job management and integration with Kafka, HDFS, and other data systems.
  humanURL: https://samza.apache.org/learn/documentation/latest/
  tags:
  - Job Management
  - REST
  - Stream Processing
  - Apache
  - Open Source
  properties:
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/latest/
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/
  - type: OpenAPI
    url: openapi/apache-samza-rest-api.yaml
  - type: NaftikoCapability
    url: capabilities/rest-checkpoints.yaml
  - type: NaftikoCapability
    url: capabilities/rest-jobs.yaml
  - type: NaftikoCapability
    url: capabilities/rest-tasks.yaml
maintainers:
- FN: Kin Lane
  email: [email protected]
common:
- type: GitHubOrganization
  url: https://github.com/apache/samza
- type: Documentation
  url: https://samza.apache.org/
- type: SpectralRules
  url: rules/apache-samza-spectral-rules.yml
- type: Vocabulary
  url: vocabulary/apache-samza-vocabulary.yaml
- type: JSONLD
  url: json-ld/apache-samza-context.jsonld
- type: Features
  data:
  - name: Kafka Integration
    description: Native Apache Kafka consumer/producer for stream processing
  - name: YARN Execution
    description: Runs on Apache YARN for resource management and fault tolerance
  - name: Stateful Processing
    description: Local state stores with RocksDB for low-latency stateful computations
  - name: Exactly-Once Processing
    description: Transactional state stores for exactly-once semantics
  - name: Flexible Deployment
    description: Run on YARN, Kubernetes, or standalone
  - name: High Level API
    description: Fluent API and SQL support for stream transformations
- type: UseCases
  data:
  - name: Event Stream Processing
    description: Real-time processing of Kafka event streams
  - name: Stateful Aggregations
    description: Windowed aggregations over streaming data
  - name: Stream Joins
    description: Join multiple Kafka streams for enrichment
  - name: Change Data Capture
    description: Process CDC events from databases in real time
- type: Integrations
  data:
  - name: Apache Kafka
    description: Primary messaging system for Samza input and output streams
  - name: Apache YARN
    description: Resource management and job scheduling on Hadoop
  - name: Apache Hadoop
    description: HDFS integration for checkpoint storage
  - name: RocksDB
    description: Embedded state store for local stateful processing