Stream Processing Simplified
Intuitive APIs for defining sources, sinks, and operators. Build complex pipelines with minimal boilerplate code.
Welcome to Cortex Data Framework
A powerful, modular, and developer-friendly SDK for building real-time data processing pipelines with built-in state management and stream processing capabilities.
Why Choose Cortex?
Section titled “Why Choose Cortex?”Rich State Management
Out-of-the-box support for multiple state stores including RocksDB, PostgreSQL, MongoDB, Cassandra, and more.
Built-in Operators
Pre-built operators for transformations, filtering, aggregations, windowing, and custom extensibility.
Production Ready
Designed for real-world scenarios with built-in concurrency handling, persistence, and fault tolerance.
Key Features
Section titled “Key Features”Real-Time Data Streaming
Process data in real-time with support for various stream sources including Kafka, RabbitMQ, AWS SQS, Azure Service Bus, and more.
Multiple State Stores
Choose from in-memory, RocksDB, PostgreSQL, MongoDB, Cassandra, ClickHouse, SQL Server, or SQLite for your state management needs.
Change Data Capture (CDC)
Built-in CDC support for MongoDB, PostgreSQL, and MS SQL Server to capture and process data changes.
Windowing & Aggregations
Support for tumbling, sliding, and session windows with powerful aggregation capabilities.
Mediator Design Pattern
Implement CQRS and other architectural patterns with built-in mediator support.
Telemetry & Monitoring
Integrate with OpenTelemetry for real-time metrics, logging, and distributed tracing.
Quick Start
Section titled “Quick Start”Get up and running with Cortex in minutes:
Getting Started
Learn the basics and set up your first stream processing pipeline.
Streams Overview
Understand stream builders, operators, and how to construct data pipelines.
Examples & Tutorials
Explore practical examples from basic to advanced use cases.
State Management
Configure and use different state stores for your applications.
Explore the Documentation
Section titled “Explore the Documentation”Stream Integration
Connect to Kafka, RabbitMQ, AWS SQS, Azure, Elasticsearch, and more.
Stream Operators
Learn about map, filter, aggregate, window, and custom operators.
Aggregations
Build complex aggregations with reduce, count, sum, average, and custom functions.
Type System
Understand Cortex’s type system with OneOf, AnyOf, and AllOf types.
Built with ❤️ by Buildersoft LLC