Overview

Quickstart

Concepts

The Stream

Endpoints

Limits

Security

Architecture

Updates

Roadmap

Rust

Python

Java

Typescript

Bento

Bytewax

Flink

gRPC API

Get a feel for how to use S2 with `grpcurl`

gRPC examples

List basins.

Get basin configuration.

Create a new basin.

Delete a basin.

Update basin configuration.

List Streams.

Get stream configuration.

Create a stream.

Delete a stream.

Update stream configuration.

Retrieve a batch of records, or set `Accept: text/event-stream` to stream using server-sent events.

Retrieve records.

Append records.

Check the sequence number that will be assigned to the next record on a stream.

Check the tail.

List access tokens.

Issue a new access token.

Revoke an access token.

Create a basin.

Get basin config.

Create or reconfigure a basin.

Reconfigure a basin.

List streams.

Create or reconfigure a stream.

Reconfigure a stream.

Community

Blog

SDKs

Integrations

gRPC

REST

v1 API (WIP)

Support

Features/SDK	Rust	Go	Python	Java	TypeScript
Core functionality
Append record auto-batching	✅	✅	✅	❌
Read session resumption	✅	✅	✅	✅	✅
Retriable idempotent requests	✅	✅	✅	✅	✅
Retry policies for appending	✅	❌	✅	✅	✅
Create with idempotence	✅	✅	✅	✅	✅
Delete with “if exists”	✅	✅	❌	❌	✅
Read session heartbeats	❌	❌	❌	❌	✅
Client configuration
Endpoints	✅	✅	✅	✅	✅
Connection timeout	✅	✅	❌	❌	❌
Request timeout	✅		✅	✅	✅
User agent	✅	✅	❌	✅	✅
Append retry policy	✅	❌	✅	✅	✅
Append session inflight bytes	✅	❌	❌	✅
Retry backoff duration	✅	✅	✅	✅	✅
Max attempts (retries)	✅	✅	✅	✅	✅
Compression	✅