Nyx-Stream v1.0.0 (Kafka/NATS Class)

Zero-Copy Memory Ring-Buffer & Partitioned Append-Only Log Broker.

INGESTION: 10.4M MSGS/S BANDWIDTH: 1.8 GB/S CLUSTER: 3 BROKERS (QUORUM)
Active Partitioned Topics
TOPIC NAME PARTITIONS ISR / REPLICAS HIGH WATERMARK RATE
payments.events 8 Partitions 3/3 ISR Offset 14,892,102 42.1k msg/s
telemetry.metrics 16 Partitions 3/3 ISR Offset 98,410,500 180.4k msg/s
ai.token_stream 4 Partitions 3/3 ISR Offset 2,190,441 8.9k msg/s
Consumer Groups Lag Tracker
group: fraud-detection-service LAG: 0 MSGS (REAL-TIME)
Active consumers: 8 workers · Partition rebalance: STABLE
group: bigquery-data-sync LAG: 142 MSGS (PROCESSING)
Active consumers: 4 workers · Micro-batch flush window: 200µs
Interactive Event Producer
[nyx-stream] Broker ID 1 listening on port 9092.
[nyx-stream] Ring-buffer allocation: 4GB memory mapped.