One folder per target account. Each has a runnable kit on Apache Iggy, built by LaserData, a README written for that company, and its one-slide pitch. CI runs every kit on a real Apache Iggy 0.9.0 broker on each push.
| Account | Use case | Folder |
|---|---|---|
| Zepto | Real-time hub stock and prices for search re-validation, beside MSK | zepto/ |
| Swiggy | Delivery partner location pings for the tracking screen and last-mile ETA, beside Confluent | swiggy/ |
| Meesho | Order-update notifications into Meecom, kept ahead of sale-day campaigns, beside Confluent | meesho/ |
| Zomato (Eternal) | Restaurant kitchen state for food preparation time predictions, beside Confluent Cloud | eternal/ |
| Rapido | On-duty captain location for ride matching and pickup tracking, beside Kafka | rapido/ |
| Porter | Driver-partner location pings for the live tracking link and pickup and drop arrivals, beside Cloud Pub/Sub | porter/ |
| Groww | Position updates from OMS fills into the Holdings service, inside the app's post-trade refresh, beside Strimzi Kafka | groww/ |
| PhonePe | Payer velocity counts for the risk check on the payer's next payment, self-hosted beside Kafka | phonepe/ |
| Razorpay | Payment downtime signals: payment status into the downtime detector, and its signals out to Checkout and merchant webhooks, beside MSK | razorpay/ |
| Zerodha | Exchange ticks to every Kite ticker node, with rebuild and replay from the log, beside NATS | zerodha/ |
| Juspay | Release guard: payment outcomes tagged with the serving release into the A/B comparison, and SCALE or ABORT back to the staggered rollout, beside Kafka and ClickHouse | juspay/ |
| JioHotstar | Playback health signals: minimized heartbeats by cohort and CDN into the health check, and CDN health signals out to routing and alerting, beside Kafka | jiohotstar/ |
| ShareChat | Viewed posts into the feed dedup service before the next feed request, beside Redpanda and WarpStream | sharechat/ |
| ZEE5 | Continue Watching heartbeats: playback position into the resume point a viewer gets on their next device, beside Confluent Cloud and ScyllaDB | zee5/ |
| MoEngage | Smart Trigger events, one topic per workspace: trigger events into the campaign evaluator at each brand's own rate, beside self-run Kafka | moengage/ |
| SigNoz | OTLP ingest buffer between gateway collectors and ClickHouse writers: bursts and ClickHouse stalls absorbed in the log, offsets committed only after ClickHouse confirms | signoz/ |
| Dream11 | Live fantasy points: every ball of every live match to every points node, with rebuild from the log, beside Kafka | dream11/ |
| The Trade Desk | Spend-to-pacing loop: every win's spend into the pacing controllers, and their pause and throttle decisions back to every bid server, beside Kafka | the-trade-desk/ |
| Magnite | DSP appetite lane for traffic shaping: which DSPs are bidding on which supply, to every shaping node, with rebuild from the log, beside Kafka | magnite/ |
| Braze | Currents connector lane: engagement events on one topic per connector, each read at its partner's pace from its own offset, so one partner's outage or rate limit delays only its own export, beside Kafka | braze/ |
| PubMatic | CTV household frequency lane: every impression to every ad server before that household's next ad decision, so caps hold across screens and servers, with rebuild from the log, beside Kafka | pubmatic/ |
| Klaviyo | Failed-writes lane for the Event Publisher: every event whose MSK publish fails captured in milliseconds and re-published inside its priority lane's SLO, with the DLQ beside it, in place of the self-hosted failed-writes Kafka cluster | klaviyo/ |
| Attentive | Subscriber decision lane: shopping events keyed by subscriber, each subscriber decided by one worker at a time with no lock, so one shopping burst queues one text, beside Pulsar | attentive/ |
| Cursor | Spend-limit lane: every billable request's usage keyed by user into the spend-limit check, and its stop back to every API server, so paid usage stops at the limit, beside WarpStream | cursor/ |
| Character.AI | Safety verdict lane: every chat turn keyed by conversation into the trust and safety classifiers, and their block and Lifeline verdicts back to every chat server before that conversation's next turn, beside WarpStream | character-ai/ |
| Deepgram | Streaming usage lane: every live stream's billable audio from the speech engine, keyed by project, into per-project, per-minute usage summaries in milliseconds, counted once even when a message is sent twice, beside the billing pipeline | deepgram/ |
| Vapi | Provider health lane: every turn's speech-to-text, LLM and voice outcome keyed by provider and region into the health evaluator, and its degraded and recovered verdicts back to every call worker before the next turn, beside MSK | vapi/ |
| StubHub | Seller listing lane: every listing change (tickets left and price) keyed by event and listing into the event pages and checkout in milliseconds, so buyers pick seats that are still there, beside Azure Event Hubs | stubhub/ |
| DoorDash | Store feedback lane for dispatch: every Dasher assigned, arrived and picked up, keyed by store with the market's utilization, into the dispatch coordinator before its next run, beside Kafka | doordash/ |
| Motive | Cargo alert lane: every Door and Environmental Sensor event keyed by asset into the alert rules, and door-outside-geofence and temperature alerts out to the driver app and back office while the door is still open, beside Kafka and Flink | motive/ |
| Rivian | Vehicle state lane: the signals the app shows (charge, locks, closures, cabin temperature, position) from every five-second vehicle report, keyed by vehicle, into the latest-state service the app reads, beside MSK | rivian/ |
| Robinhood | Card state lane for the stand-in authorizer: every change to spendable balance and card status, keyed by account, into every stand-in replica's cache in milliseconds, so stand-in decisions match the primary, on its own broker beside Kafka | robinhood/ |
| Jump Trading | Link health alert lane: every RSSI, SNR and BER sample keyed by link into the baseline and alert rules, and degraded and recovered alerts out to the network console, on-call and the status board while the link is still degraded, beside Redpanda | jump-trading/ |
| Honeycomb | Ingest freshness lane for heartbeat triggers: a receipt for every enqueued batch, keyed by dataset, and Retriever progress per Kafka partition, into the freshness check, so a dataset that went quiet pages and one stuck behind Retriever is held, beside Kafka | honeycomb/ |
| Kraken | Execution report lane: every order event keyed by account into every FIX and WebSocket gateway in milliseconds, and missed reports replayed from the log by sequence number when a session reconnects, beside Kafka and Aeron | kraken/ |
| PostHog | Live events lane: every captured event keyed by project, read directly by the node serving that project's Live view, with a newly opened view filled from the retained lane, beside MSK and WarpStream | posthog/ |
| Sentry | Crons check-in lane: every cron check-in and clock pulse, keyed by monitor, into the monitor consumer and its clock, so jobs that never checked in are marked missed and hung jobs time out the minute they are due, and a late partition holds the tick instead of marking jobs missed, beside Kafka | sentry/ |
| Atlassian | Forge usage alerts lane: every Forge function invocation's usage, keyed by app, into the allowance tracker, counted once even when sent twice, and each 50/75/90/100% crossing out to the alert service in milliseconds, beside StreamHub | atlassian/ |
| Netflix | Frequency-cap lane for ads: every impression, keyed by member profile, into the frequency-cap view of every ad server in milliseconds, through a live ad break, counted once even when delivered twice, beside Kafka and Flink | netflix/ |
| Disney | Live watch signals lane: every start, switch and stop of a live event on Disney+ and ESPN, keyed by profile, into the live personalization features before that profile's next Live rail request, beside Kinesis | disney/ |
| In-flight spend lane for ad budgets: every ad insertion's in-flight spend, keyed by ad group, into the budget view of every ad server in milliseconds, so ad groups stop at their daily budget instead of serving free ads, counted once even when sent twice, beside Kafka | pinterest/ |
|
| Discord | Osprey action lane: every action sent to the safety rules engine (messages, logins, identity changes), keyed by user, into the rules worker that owns that user, in order and in milliseconds, so the label one action adds is in place before that user's next action is evaluated, beside Pub/Sub and Kafka | discord/ |
| Conviva | Live ad break lane: every ad event from every viewer session (break start, ad attempt, impression, ad start failure, slate, break end), keyed by session, into the ad break checker in milliseconds, and each failing ad server x market cohort out to ad ops while its breaks are still running, beside Kafka, Druid and ClickHouse | conviva/ |
| REV2 safety signal lane: every ML signal keyed by content ID into the joiner that owns that content, and the fully enriched post or comment out to REV2 the moment its last signal lands, or without it past the wait limit, beside Kafka and Flink | reddit/ |
|
| Roblox | Server state lane for matchmaking: every game server's players, capacity and open or shutting-down state, keyed by server, from every edge data center into every matchmaker's index in milliseconds, through a creator update's thundering herd, with rebuild from the log, beside the matchmaking index and Kafka | roblox/ |
| Scopely | MONOPOLY GO! race lane: every dice roll in a team race, keyed by race, into the race owner that holds that race, in order and counted once when a client retries, and each lap, finish and race end out to every game server in milliseconds, so players stop rolling the moment their race is decided, through the race start's spike, beside DynamoDB and ElastiCache | scopely/ |
| AWeber | Imbi notifications lane: deployment and mention notifications from Imbi's services, keyed by project or user, into slackbot and email in milliseconds, each posted once when delivered twice, and a reader that stops moving flagged within seconds, on the Iggy server Imbi already runs beside its ClickHouse sink | aweber/ |
| Angel One | Chart candle lane: every price tick, keyed by scrip, from the on-premise price capture into the AWS candle builders, so the live candle and the 1-minute candle are final in milliseconds instead of about a second, with a DR builder that rebuilds open candles from the log, beside Kafka and MirrorMaker | angel-one/ |
| Flipkart | Billable-events lane for BCAP: every Flipkart Ads view and click keyed by campaign into the budget controller in milliseconds, charged once by canonical impression ID and minute, dropped when more than an hour late, with watermark progress per partition, and each budget stop out to every ad server, beside Flink and Pub/Sub | flipkart/ |
| Delhivery | Dock scan lane: plan revisions, load scans and seals keyed by trip into the load check, and misloads out to the loader's handheld before the next scan, beside MSK | delhivery/ |
| Myntra | Session context lane for type-ahead: every search, product view, wishlist, bag add and filter, keyed by user, folded into the shopper's session context in milliseconds, before that shopper's next type-ahead request, so suggestions lead with what they want now, beside Kafka, Spark Streaming and Aerospike | myntra/ |
| MakeMyTrip | Last-searched lane: every hotel search and hotel view, B2C and B2B on one lane, keyed by user, into the traveller's last-searched list in milliseconds, before their next tap on the search bar, beside Kafka, Spark Real-Time Mode and Aerospike | makemytrip/ |
| Ather Energy | Rider alert lane: charging, LockSafe and crash events keyed by scooter into the alert service in milliseconds, with the backlog a scooter flushes on reconnect routed by its own clock to ride history on its own topic and resends dropped by sequence, beside the MQTT broker and Kafka | ather-energy/ |
| Dhan | Live order update lane: every DEXT order status change (TRANSIT, PENDING, TRADED, Super Order legs) keyed by client ID into every order update gateway in milliseconds, and missed updates replayed from the log when a socket reconnects, beside DEXT | dhan/ |
| redBus | Bus GPS packets into boarding-point ENTRY, HALT and EXIT and an arrival alert per waiting passenger, beside Kafka | redbus/ |
| BlackBuck | Fuel alert lane: fuel-sensor pings keyed by device into the drain and refuel rules, and drain alerts out to the truck owner's app, dashboard and SMS while the fuel is still being drained, beside Kafka | blackbuck/ |
| Paytm | Soundbox payment alert lane: payment status keyed by device into the announcement service in milliseconds, announced once with the day's total, and late confirmations after a bank recovery routed by payment time to the passbook on their own topic, beside Kafka and AWS IoT | paytm/ |
| CRED | Payment status lane for Propeller: every UPI and bill payment status, cashback and coin balance keyed by member into every Propeller node in milliseconds, and missed statuses replayed from the log when a device reconnects, beside Redis and NATS | cred/ |
| Amagi | THUNDERSTORM quartile tracker lane: every ad segment served, keyed by session, into the tracker that owns it, each start and quartile beacon fired once and never for a quartile not reached, through linear break bursts and tracker restarts, beside Kinesis | amagi/ |
| Cashfree Payments | Kill Bill usage lane: every payment's txnCount and txnVolume keyed by subscription into the live day total in milliseconds, counted once by sequence and trackingId, and held in the log while Kill Bill is down, then drained with nothing lost, beside Kafka | cashfree-payments/ |
| Zeta | Account spend lane for Tachyon's transaction feature store: every approval and reversal on the primary card or a family add-on card, keyed by account, as the account's resulting spend per category, in the store before the account's next authorization, so category limits hold and reversals free room at once, beside Kafka | zeta/ |
| Pocket FM | Autoplay lane: every play, episode complete, unlock, skip and show complete, keyed by listener, into the Autoplay queue in milliseconds, before the player asks for the next show at the end of content, beside Kafka and Redis | pocket-fm/ |
| CoinDCX | Mark price lane for the liquidation engine: every futures mark batch from the partner exchange, keyed by instrument, and every position change, keyed by account, into every liquidation worker in milliseconds, so each batch is checked against every isolated and cross position before the next one, beside the feed handler and order path | coindcx/ |
| FanCode | Live scorecard lane: every score update of every live match, in six sports, keyed by match with the key scorecardPoll returns, to every scorecard node in milliseconds, with a node added for a headline match rebuilt from the log, beside Kafka and Memorystore | fancode/ |
| VerSe Dailyhunt | Ad floor lane for NexVerse.ai on Dailyhunt: every new floor per placement (language x ad slot) to every bid node in milliseconds, through breaking-news spikes, with a node added mid-spike rebuilt from the log, beside BigQuery | verse-dailyhunt/ |
| Glance (InMobi) | Lock-screen ad-state lane: every impression and dismiss beacon, keyed by user, to every ad server before that phone's next prefetch refill, so frequency caps and dismissals hold across ad servers, with rebuild from the log, beside Kafka | glance-inmobi/ |
| Sony LIV | KBC Play Along answer lane: every locked answer, keyed by player, into the scorer that owns that player, rejected after the question's close, counted once when the app retries, and scored before the answer is revealed on TV, with every score rebuildable from the log, beside Kinesis | sonyliv/ |
| CleverTap | Decision outcome lane for the Tesseract Decisioning Engine: every delivered decision and goal event (add to cart, checkout, uninstall, subscription cancellation), keyed by user, into the online learner in milliseconds, before that user's next decision, so no cart reminder follows a checkout and no message goes past the cap, beside TesseractDB | clevertap/ |
| Netcore Cloud | Delivery status lane: Sent, Delivered and Read webhooks on their own topics, keyed by message ID, with Delivered read by its own uncapped reporting writer into the campaign report within a second, counted once when a provider retries, while a Read surge waits on its own topic at its write cap, beside Pub/Sub | netcore-cloud/ |
| Gupshup | App wallet lane: every message's Gupshup fee at accept and Meta fee on delivery, keyed by app, into the live wallet balance in milliseconds, charged once when sent twice, and low, 1003 blocked and recharged states back to every send node, so campaigns stop at the overdraft limit, beside the billing pipeline | gupshup/ |
| Affle | Click-to-install lane for mFaaS: every click and install postback keyed by device into the click-to-install scorer, with each click ahead of its install, and each publisher block out to every attribution node before that publisher's next CPCU conversion is billed, beside Kafka | affle/ |
| WebEngage | Contextual Journeys trip lane: tracked events keyed by user into the worker that holds every trip (user + context) of that user, so an exit trigger such as Policy Renewed cancels its own reminder before it goes out while the user's other trips carry on, beside the existing event pipeline | webengage/ |
| Cricbuzz | Ball-by-ball commentary lane: every commentary line and correction, keyed by match and versioned per line, to every commentary node and to match alerts, with wickets overturned on review corrected everywhere and their alerts taken back, never sent twice, rebuilt from the log, beside Cricbuzz's commentary services | cricbuzz/ |
| Freshworks | Omniroute agent state lane: every agent's status, Freshcaller call, Freshchat chat and Freshdesk ticket against capacity, keyed by agent, into every routing node in milliseconds, so tickets and chats go only to agents who are available, off a call and under capacity, through a shift change, with rebuild from the log, beside self-hosted Kafka | freshworks/ |
| Postman | Insights witness lane: every Insights Agent upload batch keyed by service, from async_witnesses to witness_assembler in milliseconds, numbered per agent so a batch that never arrived is named and a retried publish counted once, beside Kafka | postman/ |
| Bharti Airtel | Domain verdict lane for Fraud Detection: every block, or block lifted, keyed by domain, to every DNS resolver and the SMS link scanner in milliseconds, before the next click on a smishing link, rebuilt from the log when a resolver is added, beside the daily database build | bharti-airtel/ |
| Jio Platforms | 5G core probe record lane: vProbe SDRs keyed by NF instance into the anomaly check, and NF health alerts out to the workflow engine, beside ATOM | jio-platforms/ |
| Last9 | Streaming aggregation lane: every raw metric sample, keyed by shard key (cluster, metric, shard_label), into the streaming aggregator that owns it in milliseconds, each timeslice closed exact against an independent count, retries counted once and counter resets handled as sum2 does, rebuilt from the log on restart, beside the gateways and storage | last9/ |
| MPL | Player form lane for matchmaking: every finished game, as the player's resulting rating and win or loss streak, keyed by player, into every matchmaker in milliseconds, so a player on a losing streak gets streak protection on the very next tap of Play again, through a live-event surge, with rebuild from the log, beside Confluent Cloud | mpl/ |
| Sarvam AI | Concurrency lane for Samvaad voice agents: every conversation start and end, keyed by organization, into the shared plan-ceiling ledger in milliseconds, and each headroom change back to every voice-agent worker before the next conversation starts, beside the existing call stack | sarvam-ai/ |
| Middleware.io | OpsAI command lane: kubectl requests keyed by cluster to the agent in each customer cluster, replies matched by request ID, each deadline checked before a command runs, so a late Auto Fix never runs, beside Pulsar | middleware-io/ |
| Twilio Segment | Destination delivery alert lane: every delivery attempt's outcome, keyed by workspace and destination, into the alert check in milliseconds, so a destination whose successful delivery rate falls below the workspace's threshold alerts within seconds of its first failures instead of on a 24-hour window, beside the delivery pipeline and Kafka | twilio-segment/ |
| Amplitude | Device throttle lane: accepted event counts from every ingestion node, keyed by device, into the throttle service's 30-second average, and each throttle back to every ingestion node before that device's next request, so a tracking loop gets its 429 wherever its requests land, beside Kafka | amplitude/ |
| Perplexity | Computer credit lane: every agent action's credits, keyed by account, into the credit ledger (bonus, then monthly, then purchased), and each pause and resume back to every agent runner, so tasks pause when the credits run out and resume when a refill lands, beside the billing platform and Stripe | perplexity/ |
| Moloco | Item status lane for Moloco Commerce Media: every stock-out, restock and Item Kill Switch block, keyed by item, to every Decision API server in milliseconds with the newest change winning, so no decision returns an item a shopper cannot buy, with a server added mid-sale rebuilt from the log, beside Pub/Sub and Kafka | moloco/ |
| Decagon | Task progress lane for Voice 3: every step of a task the reasoning layer runs, keyed by call, to the voice host serving that call before its next spoken update, beside Kafka | decagon/ |
| OpenAI | Key shutoff lane: every served API request keyed by API key into the enforcement service, and its disables for hijacked and leaked keys back to every request router before the key's next request, beside Kafka | openai/ |
| Sierra | Customer memory lane: every turn keyed by customer into the Agent Data Platform memory builder, and each customer's updated memory into the store every channel's agent reads, before that customer's next message on voice, chat or SMS, beside the Context Engine's eventing | sierra/ |
| Together AI | GPU node health lane: every passive health sample (Xid, ECC, GPU fallen off the bus, IB link flapping, thermal throttle) keyed by node into the health checker in milliseconds, and each hold with its repair action back to every placement scheduler before its next placement, while the repair waits for approval, beside the Kubernetes control plane | together-ai/ |
| Baseten | KV event lane: every block stored or evicted on every model replica, keyed by deployment, to every KV cache-aware router before the next request on that prefix, with a new router rebuilt from the log, beside the Dynamo event plane | baseten/ |
| Shopify | Buyer signal lane for Shopify Inbox: every cart add and remove, checkout and completed order, keyed by buyer and applied in one order, into the merchant's conversation in milliseconds, before the next reply from staff or the Inbox agent, beside Kafka | shopify/ |
| Uber | Surge window lane: every rider demand and driver supply event, keyed by H3 hexagon, into the surge window that owns it in milliseconds, inside the window it belongs to, so late events stop dropping out of the multiplier, with both regions' surge workers closing every window on the same counts from the same log and a restarted worker rebuilt from the log, beside Kafka and Flink | uber/ |
| Instacart | Session sequence lane for ads retrieval: every product view, item page visit and cart add, keyed by user, appended in order to the shopper's session sequence in milliseconds, before that shopper's next ads carousel (retailer home page, items to add next, pre-checkout), beside Confluent Cloud and Flink | instacart/ |
| Whatnot | Story SLO lane for E2E SLOs: every story event of a livestream join (video, auction, chat) or a bid, keyed by story key, into the story judge in milliseconds, each story judged the moment its last outcome lands or at its 60-second deadline, counted once when delivered twice, and each SLO alert out to the pager, Datadog and the incident bot, beside Kafka and ClickHouse | whatnot/ |
| Gametime | Zone Deals pool lane: every listing change (tickets left, price, seller floor) keyed by event and zone into every Zone Deals seat picker in milliseconds, through an event's final hour, with a restarted picker rebuilt from the log, beside Confluent Kafka | gametime/ |
| Copart | VB3 live lot lane: high bid, bidder flag and countdown per sale lane, keyed by lane, into every bidder-facing edge node in milliseconds, with a restarted edge rebuilt from the log, and live bids back to the auction core, beside VB3 | copart/ |
| eBay | Broadcast push lane for the Event Subscription Platform: each broadcast split into windows of 200 subscriptions on the partition of the push worker that caches them, unicast notifications on their own topic, unacknowledged pushes on a retry topic, beside Kafka | ebay/ |
| Samsara | Data Connector stream lane: updated GPS, diagnostics and events on one topic per stream subscription, keyed by vehicle, each streamed to its customer's broker from its own offset, so one customer's broker outage delays only its own stream, which backfills inside the 6-hour recovery window, beside Kinesis | samsara/ |
| Lyft | Geohash forecast lane: each region's frame of demand and supply forecasts, keyed by region, from the forecasting models to Rider Pricing and Driver Earnings, sealed per frame, with rebuild from the log, beside MSK and Flink | lyft/ |
| Tekion | Vehicle context lane: every vehicle status, price and mileage change, keyed by rooftop:VIN, into the context Salesperson AI and T1 Pro read, in milliseconds instead of a cache TTL, with rebuild from the log, beside Kafka | tekion/ |
| project44 | Position share lane: truck positions and shipment changes keyed by vehicle into the share gate, each position to the customer whose shipment is on board from the pick-up geofence until the truck leaves the delivery geofence, never after a stop, beside Kafka | project44/ |
| Faire | Fulfilled by Faire stock lane: on hand, reserved and available per SKU in the FBF warehouse, keyed brand:SKU in case packs, into the multi-brand checkout view in milliseconds instead of a periodic sync, beside Kafka | faire/ |
| Verkada | Camera partition alarm lane: camera detections, access-control disarms, arms and panic presses keyed by alarm partition into the alarm state and its entry delays, raised alarms out to monitoring agents and the response workflows, beside Kafka and Temporal | verkada/ |
| Chewy | Fulfillment center edge lane: every carton event (picked, packed, labeled, sorted, loaded, ship-confirmed), keyed by carton, into the floor view inside the building in milliseconds, held in the building's log while the link to AWS is down and drained to AWS in order afterwards, each event once, beside the WMS | chewy/ |
| Stripe | Card testing control lane: every card setup and payment attempt keyed by business into the card testing detector, and each intervention and easing back to every payments API node before the tester's next attempt, beside Kafka | stripe/ |
| Expedia Group | AdaptEx bandit decision lane: every decision (session, bandit, arm shown, such as a property's hero image), keyed by session, into every Sampler pod's consistency cache before the traveler's next page, with rebuild from the log, beside Kafka | expedia-group/ |
| PayPal | Graph link lane: every login's and profile change's account-to-asset links (device, IP, VID, address), keyed by asset, into the real-time risk graph in milliseconds, before the two-hop check on the account's next payment, beside Kafka | paypal/ |
| Block (Afterpay) | Payment token lane: every token change from the payments platform's scheduled jobs (card updater, card replaced, token revoked), keyed by customer, card numbers masked and HMAC-signed, into every subscribing service's token cache in milliseconds, so no instalment goes to a replaced card, beside Kafka | block/ |
| Affirm | Customer aggregate lane: every loan event's user-level aggregate (repaid, outstanding, charged off, overdue, disputes), keyed by customer, into the online feature store in milliseconds, so the checkout version check finds it current instead of recomputing from full history, beside Kafka and Flink | affirm/ |
| Coinbase | Chain event lane for ChainStorage: every BLOCK_ADDED and BLOCK_REMOVED event, per chain in sequence order, to every indexer in milliseconds, each resuming from its checkpoint and rebuilding from the log, beside ChainStorage's event table and gRPC stream | coinbase/ |
| Kalshi | Cross-shard order group lane: every fill in an order group, from every matching engine shard, keyed by order group, into one rolling 15-second count in milliseconds, and each trigger and reset back to every shard before its next fill, so a market maker's contracts limit holds across Sports, Combos, Crypto and the default shard, beside the engines and Kafka | kalshi/ |
| New Relic | Time-wave watermark lane: every time-wave generation emitted into a cell and every tally of its synthetic points reaching the end of the pipeline, keyed by cell and source pipeline, into a watermark service in milliseconds, so alert windows close only on complete data and a stalled cell is flagged while it is still stalled, beside Kafka | new-relic/ |
| Alpaca | Partner trade event lane: every OMS trade event, keyed by account ID, into one log per Broker API partner and out to its event stream gateway in milliseconds, with exact resume from since_id and slow partners lagging in their own log instead of dropping events, beside Redpanda | alpaca/ |
| CrowdStrike | Identity enforcement lane: every authentication keyed by account into the identity detection engine, and its blocks for lateral movement and MFA for compromised passwords back to every domain controller sensor before the account's next logon, beside Kafka | crowdstrike/ |
| Comcast NBCU | Peacock stream-limit lane: every playback session start, heartbeat and stop, keyed by account, into the stream-limit view of every playback node in milliseconds, so the three-stream limit holds across devices and a viewer switching from TV to phone is let in, with rebuild from the log, beside Kafka | comcast-nbcu/ |
| Cribl | SIEM outage lane: one Route's security events written once, each Destination reading from its own offsets, fresh events first after a SIEM outage, behind a Cribl Stream Webhook Destination | cribl/ |
| ClickHouse | Apache Iggy source for ClickPipes (partner): OpenTelemetry logs from Iggy into a ClickStack-style otel_logs table exactly once, with per-partition high-water marks, the block in flight recorded in Iggy and deterministic dedup tokens, through ClickHouse outages and pipe crashes, queryable in about half a second | clickhouse/ |
| Roku | Live floor lane for the Roku Exchange: every auction outcome, keyed by inventory segment, into the floor service in milliseconds, and every new floor out to every exchange node, so floors follow demand density through a live game's ad breaks, with a node added mid-game rebuilt from the log, beside Kafka | roku/ |
| Mux | Streaming export lane for Mux Data: every finished view, keyed by view ID, on one topic per streaming export, each written to its customer's Kinesis stream or Pub/Sub topic from its own offset, so one throttled or unreachable destination delays only its own export, beside Kafka and Kafka Connect | mux/ |
| Spotify | Episode publish status lane: every upload's receipt and stage change, keyed by episode, into the status service in milliseconds, so creators see "received and queued", re-uploads are answered from the view, and a transcoding backlog alerts within a second of crossing its line, beside Pub/Sub | spotify/ |
| The New York Times | Publish-to-site lane: every published version of every asset, keyed by top-level asset URI, to every serving node inside the one-second publish SLA, through tag republish bursts, with new nodes rebuilt from the log, beside Kafka | new-york-times/ |
| Riot Games | Match termination lane for VALORANT anti-cheat: every shot keyed by match into the anti-cheat scorer, and each match termination back to the game server running that match before the cheater's next shot lands, beside REBus and MSK | riot-games/ |
| FanDuel | In-state wallet lane: every account and wallet event a state's sportsbook accepts, keyed by account, mirrored from the site taking bets to the second site in the same state at the same offsets in milliseconds, so in-state failover loses nothing and no event leaves the state, beside Kafka | fanduel/ |
| Fox Corporation / Tubi | Creative readiness lane for the Tubi ad server: every programmatic creative a node meets for the first time, keyed by creative, into the creative registry once, and each verdict (ready with brand and ad category, or held) out to every ad server node in milliseconds, so a new flight serves on its first eligible bid, beside Kafka | fox-tubi/ |
| Optiver | Table change log beside PG feed: every committed change to config and pricing tables keyed by table, with checkpoints in the log, so a process that starts or restarts rebuilds its tables from the log instead of a fresh Postgres snapshot, and the live copy is checked against the database row for row | optiver/ |
| Real-time tracking lane: the latency-sensitive signals Tracking API sends directly to real-time processing, keyed by pseudonymized member ID, read partition by partition in milliseconds and held in the log through a reader restart with none lost, beside Kafka and Northguard | linkedin/ |
|
| Fubo | Key-play Game Alerts lane: every pitch, key play, clip-ready event and replay review keyed by game into Game Alerts, each alert pushed the moment its clip is playable, held back or corrected when a call is overturned, never pushed twice after a restart, beside Kafka and Pub/Sub | fubotv/ |
| Ditto | CDC Data Bridge lane: Big Peer document changes in Ditto's CDC event shape, keyed by _id, into every downstream system at its own offset in milliseconds, in per-document order, repeats dropped by txnId, and a system added later rebuilt from the log, beside Ditto's Kafka bridges and webhooks | ditto/ |
| Measure | Crash spike lane: one record per ingest batch after grouping (batch, session, fatal crash and ANR fingerprints), keyed by app, into the spike check, Measure's rule (100 and 0.5% of sessions in an hour, 7-day cooldown) on every batch, repeats counted once, Crash Spike and ANR Spike alerts to Slack and email in milliseconds, on the Iggy server Measure's self-host stack already runs, beside the hourly job | measure/ |
| CocoIndex | Live PR-review context for code-review agents (partner): review-thread changes from an Iggy topic into Postgres through CocoIndex's own Iggy connector, resolved threads deleted, offsets stored after each write, through an indexer crash | cocoindex/ |
| Nykaa | Ad counter lane for Nykaa Ads: every sponsored ad impression and click, keyed by shopper, into every ad selector in milliseconds, before that shopper's next page asks for ads, so caps and clicks count on the very next ad decision, with rebuild from the log, beside MSK | nykaa/ |