Diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.

Langchain + Docker + Neo4j + Ollama

Port of OpenAI's rigorous Codex review prompts (P0-P3 triage) to Google Gemini CLI slash commands.

Multi-strategy parser for messy, real-world data. Built to handle LLM responses with broken JSON, markdown wrappers, type mismatches, and inconsistent formatting.

Rust-native, pattern-first stream processing engine (CEP): filters, joins, enrichment, windows—low latency on-prem & Kubernetes.

Distributed stream processing engine in Rust

The Auron accelerator for distributed computing framework (e.g., Spark) leverages native vectorized execution to accelerate query processing

Rust Agent Development Kit

Examples and guides for using the Gemini API

Mirror of Apache Helix

Code samples for Back to Back SWE lessons (archive).

Mirror of Apache Eagle

An extensible distributed system for reliable nearline data streaming at scale

Apache Spark - A unified analytics engine for large-scale data processing

Stream Processing and Complex Event Processing Engine

A collection of design patterns/idioms in Python