Flagship · v0.1.0 testing01
Nereus
Shared stream storage for Pulsar and Native Kafka.
Stable logical offsets, explicit commit boundaries, physical generations, recovery, retention, and safe reclamation beneath protocol-facing brokers.
NereusStream
Infrastructure for durable streams and scheduled delivery.
NereusStream builds infrastructure for Apache Pulsar and Apache Kafka—from shared stream storage to durable delayed-message scheduling.
NereusStream
Nereus
Delay
Products
Two products, one infrastructure perspective.
Explore the flagship storage core and the durable scheduling system as separate products with independent source baselines and documentation.
V1 in development02
Nereus Delay
Durable delayed-message scheduling across Kafka and Pulsar destinations.
Managed scheduling, cancellation and rescheduling with durable shard state, destination isolation, explicit uncertainty, and checkpoint-based recovery.
Organization principles
Make boundaries visible.
Protocol-aware
Work with Kafka and Pulsar semantics instead of hiding their boundaries.
Explicit correctness boundaries
Distinguish durable writes, logical commits, queued commands, applied state, and uncertain outcomes.
Recoverable state
Design recovery, replay, checkpoints, retention, and cleanup as first-class paths.
Documentation
Start from the product you need.
Each product has its own reading order, source baseline, and correctness boundaries.
NereusStream
Build from durable boundaries.
Read the documentation or follow the organization repositories as each product moves toward its next verified baseline.