ruststream-kinesis

ruststream-kinesis is the Amazon Kinesis Data Streams broker for the RustStream messaging framework, built on the official aws-sdk-kinesis. On top of the SDK it supplies the coordination the vendor's consumer library provides on other platforms and the Rust SDK does not: shard discovery across splits and merges, shard leasing with fencing, and per-shard checkpointing.

Handlers, routers, codecs, and middleware come from the framework; this crate supplies the transport, and nothing broker-specific leaks back into the framework.

ruststream = { version = "0.6", features = ["macros", "json"] }
ruststream-kinesis = "0.6"
serde = { version = "1", features = ["derive"] }

crates/ruststream-kinesis/examples/kinesis_service.rs

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        KinesisBroker::new()
            .endpoint("http://localhost:4566")
            .test_credentials()
            .region("us-east-1"),
        |b| {
            b.include(handle);
        },
    )
}

Where to go next

• Kinesis guide - subscriptions, leases and checkpoints, positions, publishing, and testing.
• RustStream docs - the framework itself: subscribers, routing, codecs, middleware, the CLI.
• API reference - the crate's rustdoc on docs.rs.

How this site relates to the RustStream docs

This site documents the Kinesis broker only. Framework concepts that apply to every broker (writing subscribers, publishing, routing, codecs, middleware, observability, the CLI) live in the RustStream documentation. The pages here cover what is specific to Kinesis and link back to the framework docs where the two meet.