Stream processing, reimagined.
A modular SDK for building real-time data pipelines with built-in state management, change data capture, and stream processing — in idiomatic C#.
Stream processing, simplified.
State, the way you need it.
RocksDB, PostgreSQL, MongoDB, Cassandra, ClickHouse, SQL Server, or SQLite. Stateful aggregations and windowing work the same regardless of store.Change data capture, built in.
Observable. Resilient. Scalable.
Build pipelines with a fluent API.
Create powerful streaming pipelines in just a few lines of expressive C# code.
var app = StreamBuilder
.CreateNewStream("high-throughput-pipeline")
.WithPerformanceOptions(options => {
options.BufferCapacity = 10000;
options.MaxConcurrency = 8;
})
.From(new KafkaSource("events-topic"))
.Map(evt => Transform(evt))
.Filter(evt => evt.IsValid)
.Aggregate(TimeWindow.Of(5), Count())
.To(new DatabaseSink("analytics-db"))
.Build();Everything you need to build streaming applications.
Real-Time Data Streaming
Process millions of events per second with a fluent, type-safe API over Kafka, RabbitMQ, AWS SQS, and Azure Service Bus.
Multiple State Stores
In-memory and persistent: RocksDB, PostgreSQL, MongoDB, Cassandra, ClickHouse, SQL Server, SQLite.
Change Data Capture
Stream row-level changes from MongoDB, PostgreSQL, and MS SQL Server as they happen.
Windowing & Aggregations
Tumbling, sliding, and session windows with first-class aggregate operators.
Mediator Pattern
CQRS-ready mediator with commands, queries, notifications, and pluggable pipeline behaviors.
Telemetry & Monitoring
OpenTelemetry integration, graceful error handling, and production-grade observability out of the box.
Works with the tools you already use.
The Cortex ecosystem.
A modular set of packages designed to work together or independently.
Cortex.Streams
High-performance real-time pipeline builder with a fluent API: map, filter, aggregate, window, fan-out.
Cortex.Mediator
CQRS-ready mediator with commands, queries, notifications, and pluggable pipeline behaviors.
Cortex.States
Pluggable state stores: In-Memory, RocksDB, SQL Server, PostgreSQL, MongoDB, Cassandra, ClickHouse, SQLite.
Ready to build your next streaming application?
Get started with Cortex today and experience the power of modern .NET stream processing.