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.

Apache Samza publishes 3 APIs on the APIs.io network: Checkpoints API, Jobs API, and Tasks API. Tagged areas include Big Data, Hadoop, Kafka, Stream Processing, and Streaming.

The Apache Samza catalog on APIs.io includes 1 JSON-LD context and 2 Spectral governance rulesets.

Apache Samza’s developer surface includes documentation, engineering blog, and 7 more developer resources.

🌐 Visit website 📡 Source on GitHub

43.6/100 developing ▼ -5.0 Agent 22/100 agent aware Full breakdown ↓
scored 2026-07-28 · rubric v0.6

AccessFreemium

3 APIs 6 Features 4 Use Cases

Big DataHadoopKafkaStream ProcessingStreamingApacheOpen Source

Kin Score

Kin Score How this is scored →
scored 2026-07-28 · rubric v0.6

Composite quality — 43.6/100 · developing

Contract Quality 14.0 / 25

Developer Ergonomics 2.2 / 20

Commercial Clarity 7.9 / 20

Operational Transparency 4.8 / 13

Governance 8.3 / 12

Discoverability 6.5 / 10

Agent readiness — 22/100 · agent aware

Machine-Readable Contract 18 / 18

Agentic Access Contract 10 / 10

MCP Server 0 / 12

Machine-Readable Auth 0 / 10

Idempotency 0 / 9

Stable Error Semantics 0 / 8

Request/Response Examples 0 / 7

Rate-Limit Signaling 7 / 7

Typed Event Surface 0 / 6

Agent Skills 0 / 5

Well-Known Catalog 0 / 4

Consent & Bot Identity 0 / 3

A2A Agent Card 0 / 8

Dry-Run / Simulate Mode 0 / 4

Improve this rating by publishing the missing artifacts — every area above can be raised, and the full rubric is at apis.io/rating/. This rating is computed from github.com/api-evangelist/apache-samza: open an issue to ask a question, or submit a pull request to add artifacts. Want it done for you? Prioritized profiling — $2,500 →

APIs 3

Individual APIs this provider publishes, each with its own machine-readable definition.

Rate Limits 1

Documented rate limits and quota policies.

Apache Samza Rate Limits

5 limits

RATE LIMITS

FinOps 1

Cost, billing, and metering signals for API financial operations.

Apache Samza Finops

FINOPS

Features 6

Notable capabilities this provider offers.

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

JSON Schema 8

Standalone JSON Schema definitions for this provider's data models.

Scroll for all 8

Examples 8

Example request and response payloads for these APIs.

Scroll for all 8

AGENTIC

Use Cases 4

What developers build with this provider.

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 4

Pre-built integrations with other platforms and tools.

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

Resources

Documentation 1

Reference material describing how the API behaves

Documentation

Documentation

Agent Surfaces 1

MCP servers, agent skills, and machine-readable catalogs

AgenticAccess

AgenticAccess

Design & Contract 3

Pagination, idempotency, versioning, errors, and events

SpectralRules

SpectralRules

Vocabulary

Vocabulary

JSONLD

JSONLD

Build 1

SDKs, sample code, and the tooling you integrate with

GitHubOrganization

GitHubOrganization

Access & Security 2

Authentication, authorization, and security posture

VulnerabilityDisclosure

VulnerabilityDisclosure

DomainSecurity

DomainSecurity

Company 1

The organization behind the API

Blog

Blog

Source (apis.yml)

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
accessModel:
  pricing: freemium
  onboarding: unknown
  trial: false
  try_now: false
  public: false
  label: Freemium
  confidence: medium
  source:
  - plans
  generated: '2026-07-22'
  method: derived
position: Consumer
access: 3rd-Party
image: https://kinlane-images.s3.amazonaws.com/shared/apis-json/icons/apache-samza.png
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-checkpoints-api
  name: Apache Samza Checkpoints API
  description: The Checkpoints API from Apache Samza — 1 operation(s) for checkpoints.
  humanURL: https://samza.apache.org/learn/documentation/latest/
  tags:
  - Checkpoints
  properties:
  - type: OpenAPI
    url: openapi/apache-samza-checkpoints-api-openapi.yml
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/latest/
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/
- aid: apache-samza:apache-samza-jobs-api
  name: Apache Samza Jobs API
  description: The Jobs API from Apache Samza — 4 operation(s) for jobs.
  humanURL: https://samza.apache.org/learn/documentation/latest/
  tags:
  - Jobs
  properties:
  - type: OpenAPI
    url: openapi/apache-samza-jobs-api-openapi.yml
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/latest/
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/
- aid: apache-samza:apache-samza-tasks-api
  name: Apache Samza Tasks API
  description: The Tasks API from Apache Samza — 1 operation(s) for tasks.
  humanURL: https://samza.apache.org/learn/documentation/latest/
  tags:
  - Tasks
  properties:
  - type: OpenAPI
    url: openapi/apache-samza-tasks-api-openapi.yml
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/latest/
  - type: Documentation
    url: https://samza.apache.org/learn/documentation/
maintainers:
- FN: Kin Lane
  email: info@apievangelist.com
common:
- type: AgenticAccess
  url: agentic-access/apache-samza-agentic-access.yml
- type: VulnerabilityDisclosure
  url: security/apache-samza-vulnerability-disclosure.yml
- type: DomainSecurity
  url: security/apache-samza-domain-security.yml
- 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
- type: Blog
  url: https://samza.apache.org/blog/