Real-time observability for silent failures. Built on the premise that detection is a verification problem, not a collection problem.
Go · Kafka · OpenTelemetry · WebSocket · early access
A rebalancer for production Kafka, built solo: 17,000+ partition leaders and 50,000+ replicas redistributed in batches of 200, gated by broker disk thresholds. Rebalancing stopped being a maintenance window and became a command.
Python · Kafka internals · Salt · in production · field notes ↗
Designed and implemented end to end: a Go daemon for a service-continuity platform that continuously discovers suspended subscriptions and restores the ones that qualify. Remediation as a daemon rather than a runbook.
Go · Redis · GraphQL · Nomad · in production
First a topic-ownership service, designed and implemented end to end, aggregating ACLs, log dirs and consumer groups. Then, having hit the limits of hand-rolled metadata, DataHub: ElasticSearch reliability and schema-registry integration, contributed upstream to LinkedIn's open source.
Python · Java · ElasticSearch · Confluent Schema Registry
RCS is now widely supported across Android and, since 2024, iPhone: a decade after this work, it has become a mainstream mobile messaging standard, with end-to-end encryption arriving in the Universal Profile. A decade before that, I built the subscriber-data layer such networks need: MySQL, MongoDB and Redis exposed as one OData repository inside a live IMS core. Infrastructure for a standard the world had not adopted yet.
Java EE · OData · MySQL · MongoDB · Redis · Open IMS Core · 11,575 LOC · read the thesis ↗
First P4 implementation of IEEE 802.1CB frame replication, built clause by clause on a nine-switch bmv2 smart grid testbed, with the ONOS P4Runtime driver written to support it. Worked the hardware path on Netronome SmartNICs before running the full testbed on software switches: same proof, none of the cost.
P4 · ONOS · bmv2 · Mininet · SDN · NFV · live testbed