Streaming

Streaming is a topic catalog of the protocols, platforms, and processing engines used to move and transform real-time, high-volume, often bidirectional data over the network. It indexes the canonical log-structured and broker systems (Apache Kafka, Apache Pulsar, Redpanda, NATS JetStream, AWS Kinesis, GCP Pub/Sub + Dataflow, Azure Event Hubs, Confluent Cloud, StreamNative), the over-the-wire streaming protocols exposed to API consumers (Server-Sent Events, WebSocket, gRPC streaming, GraphQL subscriptions), the change-data capture and connector frameworks that feed them (Kafka Connect, Debezium), and the stream-processing engines that consume them (Apache Flink, Spark Structured Streaming, Materialize, Tinybird, Bytewax, Apache Beam). This topic is distinguished from `events` and `async-apis`: streaming emphasizes real-time, high-throughput, partitioned, and often bidirectional pipes, rather than discrete event envelopes or static contract documents.

Streaming publishes 21 APIs on the APIs.io network. Tagged areas include Streaming, Real-Time, Event Streaming, Change Data Capture, and Stream Processing.

The Streaming catalog on APIs.io includes 1 JSON-LD context and 1 Spectral governance ruleset.

Streaming’s developer surface includes code examples and 14 more developer resources.

📡 Source on GitHub

24.4/100 emerging ▬ flat Agent 1/100 human only self hosted · Apache-2.0 Full breakdown ↓
scored 2026-09-14 · rubric v0.22.0

21 APIs

Streaming Real-Time Event Streaming Change Data Capture Stream Processing Server-Sent Events WebSocket gRPCGraphQL SubscriptionsKafkaPulsarKinesisFlink

Kin Score

Kin Score How this is scored →
scored 2026-09-14 · rubric v0.22.0

Composite quality — 24.4/100 · emerging

Contract Quality 4.8 / 23

Developer Ergonomics 1.7 / 18

Access Clarity 0.0 / 18

Operational Transparency 1.8 / 12

Contract Governance 2.7 / 11

Discoverability 5.8 / 9

Open Source Surface 7.5 / 10

Agent readiness — 1/100 · human only

Machine-Readable Contract 0 / 18

Agentic Access Contract 0 / 10

Documented Reversibility 0 / 6

MCP Server 0 / 12

Machine-Readable Auth 0 / 10

Idempotency 0 / 9

Stable Error Semantics 0 / 8

Request/Response Examples 7 / 7

Rate-Limit Signaling 0 / 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

Delegated User Identity 0 / 6

Protected Resource Metadata 0 / 5

Registration Without a Human 0 / 6

Agentic Commerce Well-Known Document 0 / 5

Open Source Surface applies to this provider. This product is open source and we read its repository directly, so Open Source Surface carries 10 points of the composite. It is scored from what the repository actually publishes — a security policy, a contribution guide, a release history, a code of conduct — read live from the provider rather than inferred from our own catalog pointers. This facet adds; nothing was taken away to make room for it. An open-source project is not excused from the commercial facets, because exemption would strip it of the points it does earn. If we have the wrong repository, or this product is not open source, say so on your provider repo and we will drop the facet rather than have you publish against it.

Create-or-Update Ergonomics could not be measured. We hold no machine-readable contract for this provider to read, so there is nothing to measure a write surface against. Excluded rather than scored zero: never-measured and measured-empty are different facts. Publishing an OpenAPI is what makes this facet — and several others — scorable at all.

The six quality facets above are damped to 90 points between them, because the conditional facet above carries the other 10. That is why each facet's contribution is shown against a damped maximum: raising a quality facet moves the composite by 90% of its nominal weight, not 100%. The full arithmetic is at apis.io/rating/.

Improve this rating by publishing the missing artifacts — every area above can be raised, and the full rubric is at apis.io/rating/. Every facet and dimension name above is a link: it opens that measurement's own page — what it means, the exact checks that feed it, how the whole catalog distributes on it, and the providers at the top of it. This rating is computed from github.com/api-evangelist/streaming: open an issue to ask a question, or submit a pull request to add artifacts. Submit an artifact on GitHub — free → Manage your own listing — the Influence plan, $499/mo →

APIs 21

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

Apache Kafka

Distributed, partitioned, replicated log. The reference open-source streaming platform; durable, ordered topics with consumer groups, exactly -once semantics, and the de facto w...

Apache Pulsar

Cloud-native, multi-tenant pub/sub and streaming platform with a tiered storage architecture (BookKeeper) that separates compute from storage, native geo-replication, and built-...

Redpanda

Kafka-API-compatible streaming platform implemented in C++ with no ZooKeeper/JVM dependency. Single binary, thread-per-core architecture, Raft consensus; positioned as a drop-in...

NATS JetStream

Persistence layer for the NATS messaging system providing at-least-once and exactly-once streaming, key/value and object stores, and durable consumers — designed for edge, IoT, ...

Amazon Kinesis

AWS managed family for real-time streaming: Kinesis Data Streams (shards, partition keys, 24h–365d retention), Kinesis Data Firehose (delivery to S3/Redshift/OpenSearch), and Ki...

Google Cloud Pub/Sub and Dataflow

GCP's managed messaging (Pub/Sub) and stream-processing (Dataflow, built on Apache Beam) stack. Pub/Sub provides at-least-once and exactly-once delivery with push/pull subscribe...

Azure Event Hubs

Microsoft's managed big-data streaming platform; Kafka-protocol compatible, partitioned, with Capture (delivery to ADLS/Blob) and tight integration with Azure Stream Analytics a...

Confluent Cloud

Managed Kafka by the original Kafka authors. Cluster, topic, connector, KSQL, Schema Registry, Stream Governance, and Flink offerings exposed via a Confluent Cloud REST API and ...

StreamNative

Managed Apache Pulsar as a service from Pulsar's original contributors, with multi-cloud clusters, Functions, sources/sinks, and a control-plane REST API.

Server-Sent Events (SSE)

One-directional HTTP-based streaming from server to client using the `text/event-stream` media type. Defined by the HTML Living Standard EventSource API; widely used for LLM tok...

WebSocket

Full-duplex, bidirectional streaming protocol over a single TCP connection, upgraded from HTTP. RFC 6455. Foundation for chat, collaborative apps, market data, and real-time con...

gRPC Streaming

gRPC defines four RPC styles, three of which are streaming: server streaming, client streaming, and bidirectional streaming, all multiplexed over HTTP/2. The default streaming s...

GraphQL Subscriptions

The GraphQL operation type for receiving a stream of updates over a long-lived transport (typically WebSocket via the graphql-ws or graphql-transport-ws sub-protocols, or SSE). ...

Kafka Connect

Framework and runtime for source/sink connectors that move data into and out of Kafka. Distributed mode runs a REST-controlled cluster of workers managing connector and task lif...

Debezium

Change-data-capture (CDC) platform that streams row-level database changes (Postgres, MySQL, MongoDB, SQL Server, Oracle, Cassandra) as Kafka records using each database's nativ...

Apache Flink

Distributed, stateful stream-processing engine with event-time semantics, windowing, watermarks, and exactly-once state. SQL, DataStream, and Table APIs; reference engine for su...

Spark Structured Streaming

Stream-processing API built on Spark SQL using a micro-batch (and experimental continuous) execution model. Treats a stream as an unbounded table.

Materialize

Operational data warehouse and streaming SQL database built on Differential Dataflow. Maintains incrementally updated materialized views over streaming sources with millisecond ...

Tinybird

Real-time analytics platform built on ClickHouse; ingests streams via HTTP, Kafka, or CDC, exposes SQL pipes as parameterized HTTP API endpoints with auth tokens.

Bytewax

Open-source Python-native stream-processing framework built on Timely Dataflow; targets data scientists and Python teams building real-time ML and data pipelines.

Apache Beam

Unified batch and streaming programming model. Beam pipelines run on multiple runners (Dataflow, Flink, Spark, Samza), defining the canonical event-time / watermark / window / t...

Scroll for all 21

GraphQL 1

GraphQL schemas published by this provider.

Streaming GraphQL API

The GraphQL operation type for receiving a stream of updates over a long-lived transport (typically WebSocket via the graphql-ws or graphql-transport-ws sub-protocols, or SSE). ...

GRAPHQL

Semantic Vocabularies 1

JSON-LD contexts and semantic vocabularies used across these APIs.

Streaming Context

49 classes · 11 properties

JSON-LD

Spectral Rules 1

Spectral governance rulesets for linting and validating these APIs.

Streaming API Rules

5 rules · 4 warnings 1 info

SPECTRAL

JSON Schema 3

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

Stream Platform

16 properties

JSON SCHEMA

Stream Record

12 properties

JSON SCHEMA

Stream

16 properties

JSON SCHEMA

JSON Structure 1

JSON Structure definitions describing this provider's data shapes.

Streaming Stream Structure

15 properties

JSON STRUCTURE

Examples 3

Example request and response payloads for these APIs.

Streaming Stream Example

16 fields

EXAMPLE

Streaming Stream Platform Example

16 fields

EXAMPLE

Streaming Stream Record Example

12 fields

EXAMPLE

Security Posture 2

Authentication, domain security, vulnerability disclosure, and trust-center signals.

Streaming Domain Security

TLSv1.3 · HSTS · DNSSEC · DMARC

SECURITY

Streaming Vulnerability Disclosure

security.txt · contact published

SECURITY

Resources

Documentation 4

Reference material describing how the API behaves

ContributionGuide

JSONSchema

JSONSchema

JSONSchema

Design & Contract 2

Pagination, idempotency, versioning, errors, and events

JSONLD

JSONLD

Vocabulary

Vocabulary

Build 4

SDKs, sample code, and the tooling you integrate with

CodeOfConduct

Examples

Examples

Examples

Access & Security 3

Authentication, authorization, and security posture

SecurityPolicy

SecurityPolicy

VulnerabilityDisclosure

VulnerabilityDisclosure

DomainSecurity

DomainSecurity

Operate 1

Status, limits, changes, and where to get help

IssueTracker

IssueTracker

Commercial 1

Pricing, plans, and the legal terms of use

License

License

Source (apis.yml)

aid: streaming
name: Streaming
description: 'Streaming is a topic catalog of the protocols, platforms, and processing engines used to move and transform
  real-time, high-volume, often bidirectional data over the network. It indexes the canonical log-structured and broker systems
  (Apache Kafka, Apache Pulsar, Redpanda, NATS JetStream, AWS Kinesis, GCP Pub/Sub + Dataflow, Azure Event Hubs, Confluent
  Cloud, StreamNative), the over-the-wire streaming protocols exposed to API consumers (Server-Sent Events, WebSocket, gRPC
  streaming, GraphQL subscriptions), the change-data capture and connector frameworks that feed them (Kafka Connect, Debezium),
  and the stream-processing engines that consume them (Apache Flink, Spark Structured Streaming, Materialize, Tinybird, Bytewax,
  Apache Beam). This topic is distinguished from `events` and `async-apis`: streaming emphasizes real-time, high-throughput,
  partitioned, and often bidirectional pipes, rather than discrete event envelopes or static contract documents.'
type: Index
deliveryModel:
  model: self-hosted
  license: Apache-2.0
  open_source: true
  commercial: false
  callable_host: false
  label: Self-hosted open source · you run it yourself
  confidence: high
  source:
  - license
  generated: '2026-08-28'
  method: derived
accessModel:
  pricing: unknown
  onboarding: unknown
  trial: false
  try_now: false
  public: false
  label: Unknown
  confidence: low
  source: []
  generated: '2026-07-22'
  method: derived
position: Consuming
access: 3rd-Party
image: https://kinlane-images.s3.amazonaws.com/shared/apis-json/icons/streaming.png
tags:
- Streaming
- Real-Time
- Event Streaming
- Change Data Capture
- Stream Processing
- Server-Sent Events
- WebSocket
- gRPC
- GraphQL Subscriptions
- Kafka
- Pulsar
- Kinesis
- Flink
tags_raw:
- Streaming
- Real Time
- Event Streaming
- Change Data Capture
- Stream Processing
- Server Sent Events
- WebSocket
- gRPC
- GraphQL Subscriptions
- Kafka
- Pulsar
- Kinesis
- Flink
created: '2026-05-22'
modified: '2026-05-22'
url: https://raw.githubusercontent.com/api-evangelist/streaming/refs/heads/main/apis.yml
specificationVersion: '0.23'
apis:
- aid: streaming:apache-kafka
  name: Apache Kafka
  description: Distributed, partitioned, replicated log. The reference open-source streaming platform; durable, ordered topics
    with consumer groups, exactly -once semantics, and the de facto wire protocol for the streaming ecosystem. Native Kafka
    clients and a REST proxy expose the broker.
  humanURL: https://kafka.apache.org
  tags:
  - Streaming
  - Log
  - Open-Source
  - Apache Software Foundation
  tags_raw:
  - Streaming
  - Log
  - Open Source
  - Apache Software Foundation
  properties:
  - type: Documentation
    url: https://kafka.apache.org/documentation/
  - type: GitHubRepository
    url: https://github.com/apache/kafka
  - type: Topic
    url: https://github.com/api-evangelist/apache-kafka
- aid: streaming:apache-pulsar
  name: Apache Pulsar
  description: Cloud-native, multi-tenant pub/sub and streaming platform with a tiered storage architecture (BookKeeper) that
    separates compute from storage, native geo-replication, and built-in Functions for lightweight stream processing.
  humanURL: https://pulsar.apache.org
  tags:
  - Streaming
  - Pub-Sub
  - Open-Source
  - Apache Software Foundation
  tags_raw:
  - Streaming
  - Pub Sub
  - Open Source
  - Apache Software Foundation
  properties:
  - type: Documentation
    url: https://pulsar.apache.org/docs/
  - type: GitHubRepository
    url: https://github.com/apache/pulsar
  - type: Topic
    url: https://github.com/api-evangelist/apache-pulsar
- aid: streaming:redpanda
  name: Redpanda
  description: Kafka-API-compatible streaming platform implemented in C++ with no ZooKeeper/JVM dependency. Single binary,
    thread-per-core architecture, Raft consensus; positioned as a drop-in for Kafka workloads.
  humanURL: https://redpanda.com
  tags:
  - Streaming
  - Kafka Compatible
  - Open-Source
  tags_raw:
  - Streaming
  - Kafka Compatible
  - Open Source
  properties:
  - type: Documentation
    url: https://docs.redpanda.com
  - type: GitHubRepository
    url: https://github.com/redpanda-data/redpanda
- aid: streaming:nats-jetstream
  name: NATS JetStream
  description: Persistence layer for the NATS messaging system providing at-least-once and exactly-once streaming, key/value
    and object stores, and durable consumers — designed for edge, IoT, and microservice topologies.
  humanURL: https://nats.io/
  tags:
  - Streaming
  - Messaging
  - Open-Source
  - CNCF
  tags_raw:
  - Streaming
  - Messaging
  - Open Source
  - CNCF
  properties:
  - type: Documentation
    url: https://docs.nats.io/nats-concepts/jetstream
  - type: GitHubRepository
    url: https://github.com/nats-io/nats-server
- aid: streaming:aws-kinesis
  name: Amazon Kinesis
  description: 'AWS managed family for real-time streaming: Kinesis Data Streams (shards, partition keys, 24h–365d retention),
    Kinesis Data Firehose (delivery to S3/Redshift/OpenSearch), and Kinesis Video Streams for media. HTTP/2 SubscribeToShard
    for low-latency consumers.'
  humanURL: https://aws.amazon.com/kinesis/
  tags:
  - Streaming
  - AWS
  - Managed
  properties:
  - type: Documentation
    url: https://docs.aws.amazon.com/kinesis/
  - type: Topic
    url: https://github.com/api-evangelist/amazon-kinesis
- aid: streaming:gcp-pubsub
  name: Google Cloud Pub/Sub and Dataflow
  description: GCP's managed messaging (Pub/Sub) and stream-processing (Dataflow, built on Apache Beam) stack. Pub/Sub provides
    at-least-once and exactly-once delivery with push/pull subscribers; Dataflow runs windowed, watermark-aware Beam pipelines.
  humanURL: https://cloud.google.com/pubsub
  tags:
  - Streaming
  - GCP
  - Managed
  properties:
  - type: Documentation
    url: https://cloud.google.com/pubsub/docs
  - type: Documentation
    url: https://cloud.google.com/dataflow/docs
- aid: streaming:azure-event-hubs
  name: Azure Event Hubs
  description: Microsoft's managed big-data streaming platform; Kafka-protocol compatible, partitioned, with Capture (delivery
    to ADLS/Blob) and tight integration with Azure Stream Analytics and Functions.
  humanURL: https://azure.microsoft.com/en-us/products/event-hubs/
  tags:
  - Streaming
  - Azure
  - Kafka Compatible
  properties:
  - type: Documentation
    url: https://learn.microsoft.com/en-us/azure/event-hubs/
- aid: streaming:confluent-cloud
  name: Confluent Cloud
  description: Managed Kafka by the original Kafka authors. Cluster, topic, connector, KSQL, Schema Registry, Stream Governance,
    and Flink offerings exposed via a Confluent Cloud REST API and Terraform provider.
  humanURL: https://www.confluent.io/confluent-cloud/
  tags:
  - Streaming
  - Kafka
  - Managed
  properties:
  - type: Documentation
    url: https://docs.confluent.io/cloud/current/overview.html
  - type: Topic
    url: https://github.com/api-evangelist/confluent-the-data-streaming-platform
- aid: streaming:streamnative
  name: StreamNative
  description: Managed Apache Pulsar as a service from Pulsar's original contributors, with multi-cloud clusters, Functions,
    sources/sinks, and a control-plane REST API.
  humanURL: https://streamnative.io
  tags:
  - Streaming
  - Pulsar
  - Managed
  properties:
  - type: Documentation
    url: https://docs.streamnative.io
- aid: streaming:server-sent-events
  name: Server-Sent Events (SSE)
  description: One-directional HTTP-based streaming from server to client using the `text/event-stream` media type. Defined
    by the HTML Living Standard EventSource API; widely used for LLM token streams, dashboards, and live feeds where bidirectionality
    is not required.
  humanURL: https://html.spec.whatwg.org/multipage/server-sent-events.html
  tags:
  - Streaming
  - HTTP
  - Protocol
  - Standard
  properties:
  - type: Documentation
    url: https://html.spec.whatwg.org/multipage/server-sent-events.html
  - type: Documentation
    url: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events
- aid: streaming:websocket
  name: WebSocket
  description: Full-duplex, bidirectional streaming protocol over a single TCP connection, upgraded from HTTP. RFC 6455. Foundation
    for chat, collaborative apps, market data, and real-time control planes.
  humanURL: https://datatracker.ietf.org/doc/html/rfc6455
  tags:
  - Streaming
  - Protocol
  - Standard
  - IETF
  properties:
  - type: Documentation
    url: https://datatracker.ietf.org/doc/html/rfc6455
  - type: Documentation
    url: https://developer.mozilla.org/en-US/docs/Web/API/WebSockets_API
- aid: streaming:grpc-streaming
  name: gRPC Streaming
  description: 'gRPC defines four RPC styles, three of which are streaming: server streaming, client streaming, and bidirectional
    streaming, all multiplexed over HTTP/2. The default streaming surface for service-to-service systems and Kubernetes-native
    APIs.'
  humanURL: https://grpc.io
  tags:
  - Streaming
  - Protocol
  - HTTP/2
  - CNCF
  tags_raw:
  - Streaming
  - Protocol
  - HTTP2
  - CNCF
  properties:
  - type: Documentation
    url: https://grpc.io/docs/what-is-grpc/core-concepts/
  - type: GitHubRepository
    url: https://github.com/grpc/grpc
- aid: streaming:graphql-subscriptions
  name: GraphQL Subscriptions
  description: The GraphQL operation type for receiving a stream of updates over a long-lived transport (typically WebSocket
    via the graphql-ws or graphql-transport-ws sub-protocols, or SSE). Used to push schema- defined deltas to clients.
  humanURL: https://spec.graphql.org/draft/#sec-Subscription
  tags:
  - Streaming
  - GraphQL
  - Standard
  properties:
  - type: Documentation
    url: https://spec.graphql.org/draft/#sec-Subscription
  - type: Documentation
    url: https://github.com/enisdenjo/graphql-ws
  - url: graphql/streaming-graphql.md
    type: GraphQL
- aid: streaming:kafka-connect
  name: Kafka Connect
  description: Framework and runtime for source/sink connectors that move data into and out of Kafka. Distributed mode runs
    a REST-controlled cluster of workers managing connector and task lifecycle.
  humanURL: https://kafka.apache.org/documentation/#connect
  tags:
  - Streaming
  - Connectors
  - Kafka
  - Open-Source
  tags_raw:
  - Streaming
  - Connectors
  - Kafka
  - Open Source
  properties:
  - type: Documentation
    url: https://kafka.apache.org/documentation/#connect
  - type: Topic
    url: https://github.com/api-evangelist/kafka-connect
- aid: streaming:debezium
  name: Debezium
  description: Change-data-capture (CDC) platform that streams row-level database changes (Postgres, MySQL, MongoDB, SQL Server,
    Oracle, Cassandra) as Kafka records using each database's native replication log.
  humanURL: https://debezium.io
  tags:
  - Streaming
  - Change Data Capture
  - Open-Source
  - Red Hat
  tags_raw:
  - Streaming
  - Change Data Capture
  - Open Source
  - Red Hat
  properties:
  - type: Documentation
    url: https://debezium.io/documentation/
  - type: GitHubRepository
    url: https://github.com/debezium/debezium
- aid: streaming:apache-flink
  name: Apache Flink
  description: Distributed, stateful stream-processing engine with event-time semantics, windowing, watermarks, and exactly-once
    state. SQL, DataStream, and Table APIs; reference engine for sub-second latency analytics on streams.
  humanURL: https://flink.apache.org
  tags:
  - Streaming
  - Stream Processing
  - Open-Source
  - Apache Software Foundation
  tags_raw:
  - Streaming
  - Stream Processing
  - Open Source
  - Apache Software Foundation
  properties:
  - type: Documentation
    url: https://nightlies.apache.org/flink/flink-docs-stable/
  - type: GitHubRepository
    url: https://github.com/apache/flink
  - type: Topic
    url: https://github.com/api-evangelist/apache-flink
- aid: streaming:spark-structured-streaming
  name: Spark Structured Streaming
  description: Stream-processing API built on Spark SQL using a micro-batch (and experimental continuous) execution model.
    Treats a stream as an unbounded table.
  humanURL: https://spark.apache.org/streaming/
  tags:
  - Streaming
  - Stream Processing
  - Open-Source
  - Apache Software Foundation
  tags_raw:
  - Streaming
  - Stream Processing
  - Open Source
  - Apache Software Foundation
  properties:
  - type: Documentation
    url: https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html
- aid: streaming:materialize
  name: Materialize
  description: Operational data warehouse and streaming SQL database built on Differential Dataflow. Maintains incrementally
    updated materialized views over streaming sources with millisecond freshness.
  humanURL: https://materialize.com
  tags:
  - Streaming
  - Streaming SQL
  - Database
  properties:
  - type: Documentation
    url: https://materialize.com/docs/
  - type: Topic
    url: https://github.com/api-evangelist/materialize
- aid: streaming:tinybird
  name: Tinybird
  description: Real-time analytics platform built on ClickHouse; ingests streams via HTTP, Kafka, or CDC, exposes SQL pipes
    as parameterized HTTP API endpoints with auth tokens.
  humanURL: https://www.tinybird.co
  tags:
  - Streaming
  - Real-Time Analytics
  - ClickHouse
  tags_raw:
  - Streaming
  - Real Time Analytics
  - ClickHouse
  properties:
  - type: Documentation
    url: https://www.tinybird.co/docs
- aid: streaming:bytewax
  name: Bytewax
  description: Open-source Python-native stream-processing framework built on Timely Dataflow; targets data scientists and
    Python teams building real-time ML and data pipelines.
  humanURL: https://bytewax.io
  tags:
  - Streaming
  - Stream Processing
  - Python
  - Open-Source
  tags_raw:
  - Streaming
  - Stream Processing
  - Python
  - Open Source
  properties:
  - type: Documentation
    url: https://docs.bytewax.io
  - type: GitHubRepository
    url: https://github.com/bytewax/bytewax
- aid: streaming:apache-beam
  name: Apache Beam
  description: Unified batch and streaming programming model. Beam pipelines run on multiple runners (Dataflow, Flink, Spark,
    Samza), defining the canonical event-time / watermark / window / trigger semantics for stream processing.
  humanURL: https://beam.apache.org
  tags:
  - Streaming
  - Stream Processing
  - Open-Source
  - Apache Software Foundation
  tags_raw:
  - Streaming
  - Stream Processing
  - Open Source
  - Apache Software Foundation
  properties:
  - type: Documentation
    url: https://beam.apache.org/documentation/
  - type: GitHubRepository
    url: https://github.com/apache/beam
common:
- type: IssueTracker
  url: https://github.com/apache/kafka/issues
- type: SecurityPolicy
  url: https://github.com/apache/kafka/blob/trunk/SECURITY.md
- type: CodeOfConduct
  url: https://github.com/apache/.github/blob/main/.github/CODE_OF_CONDUCT.md
- type: ContributionGuide
  url: https://github.com/apache/kafka/blob/trunk/CONTRIBUTING.md
- type: License
  name: Apache-2.0
  url: https://github.com/apache/kafka/blob/trunk/LICENSE
- type: VulnerabilityDisclosure
  url: security/streaming-vulnerability-disclosure.yml
- type: DomainSecurity
  url: security/streaming-domain-security.yml
- type: JSONSchema
  url: json-schema/streaming-stream-schema.json
- type: JSONSchema
  url: json-schema/streaming-stream-record-schema.json
- type: JSONSchema
  url: json-schema/streaming-stream-platform-schema.json
- type: JSONLD
  url: json-ld/streaming-context.jsonld
- type: Vocabulary
  url: vocabulary/streaming-vocabulary.yml
- type: Examples
  url: examples/streaming-stream-example.json
- type: Examples
  url: examples/streaming-stream-record-example.json
- type: Examples
  url: examples/streaming-stream-platform-example.json
include: []
maintainers:
- FN: Kin Lane
  email: info@apievangelist.com
  X-twitter: apievangelist

Work with this as data

Every provider here is available over the APIs.io API and to AI agents over MCP.

MCP server

One button, every client — Claude, Cursor, VS Code and the rest.

https://apis.io/mcp

Tools for providers

9 MCP tools reach this

find_providersBrowse and filter every provider in the catalog.
get_provider_artifactsEvery artifact this provider publishes, grouped by type.
get_provider_operationsEvery operation across all of their OpenAPIs — one call instead of parsing every spec.
get_provider_toolsEvery MCP tool they ship, with the operation each wraps.
get_provider_evidenceHow each part of their score was established. Free — the basis for a claim should not sit behind it.
get_provider_ratingPRO — composite, band, trend and facet scores.
apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.
resolveTurn a domain, URL or GitHub org into the provider it belongs to.
find_cohortsEvery scored population of providers in the catalog.

All 92 tools →

Call it yourself

curl for this page

This provider

curl "https://apis.io/api/v1/providers/streaming"

All providers

curl "https://apis.io/api/v1/providers?limit=25"

Every operation they expose

curl "https://apis.io/api/v1/providers/streaming/operations?limit=25"

How their score was established

curl "https://apis.io/api/v1/providers/streaming/evidence"

Discovery needs no key. Ratings and market analysis are Pro.

Get an API key

Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.

GitHub Google LinkedIn

A second provider on the same verified email joins the account you already have.