News
The Death of Notifications: Why Software Needs to Learn How to Converse
4+ hour, 48+ min ago (1022+ words) They have become more sophisticated, but no less annoying. Despite all smart scheduling, user preferences, digest emails, quiet hours, and whatnot, notifications are still a one-way street. The only way machines message their beloved humans. AI isn't about to change…...
Building an Enterprise-Grade Real-Time Analytics Pipeline with Fast API and Timescale DB
2+ hour, 24+ min ago (102+ words) I just released v1. 0. 0 of an open-source, production-ready real-time analytics pipeline built with Python. Here's what it does and why you might care. Every Saa S product needs analytics " event tracking, real-time dashboards, time-series aggregations. Most teams either pay for Segment…...
Exactly Once in Kafka Explained Simply: How Kafka Consumer Ensures No Duplicate Processing
13+ hour, 20+ min ago (1612+ words) Exactly Once isn't about preventing failures. It's about ensuring failures don't change the final business outcome." Imagine you're managing a warehouse. There are 100 boxes in stock. A customer buys 1 box. The system updates the stock. But immediately after updating the…...
Designing a Reliable Wallet Engine: Event-Driven Architecture with Kafka and Type Script
21+ hour, 41+ min ago (894+ words) If you've ever built a fintech product, you know this truth: the hardest part isn't moving money " it's making sure you never lose it. A wallet engine sounds simple on the surface. Credit. Debit. Balance. But the moment you introduce…...
Black Bull goes multi-protocol (part 3) " one `app. py`, two protocols
2+ day, 3+ hour ago (217+ words) The first two posts were the engineering: part 1 rebuilt the connection dispatcher so Black Bull's core stopped assuming HTTP, and part 2 put a lock-free, single-owner MQTT 5 broker on top of that seam. This post is the payoff " what all of…...
Can you build observability ingestion on S3 alone " no Kafka, no disks, no coordination layer?
2+ day, 23+ hour ago (550+ words) We replaced a Kafka + Flink + OTel pipeline (~$700800/mo at 10 MB/s) with one engine where the data, the WAL, and the Apache Iceberg catalog all live in S3 " no stateful layer to operate. Here's how it works. Tagged with rust, observability, aws,…...
Scheduled and delayed messages: Routing with TTL and dead-letter exchange in Rabbit MQ
3+ day, 3+ hour ago (102+ words) Often, we need to delay message delivery in our messaging architectures: for example, sending a reminder email 2 hours after account creation, or retrying a temporarily failed transaction after a planned 10-minute delay. While Rabbit MQ offers an official delayed messages…...
Building a Simple Event-Driven Application with Datadog Workflows
3+ day, 10+ hour ago (615+ words) By: Logan Rohloff on June 30, 2026 Back in October 2022, I wrote a short blog post explaining how I automated our Datadog Marketplace sales cycle using a few AWS services and my first-ever Golang program. That basic, event-driven system saved our sales…...
Designing a strongly-consistent event exchange on Amazon Aurora DSQL
4+ day, 4+ hour ago (383+ words) Every exchange " equities, prediction markets, ticketing " reduces to one hard problem: a correct, always-on, globally consistent ledger. Traditionally that demands three separate things before a single order is matched: Parity is an experiment in collapsing all three into one primitive…...
" Solo Engine v0. 3. 0 Release " Checkpoint Mechanism & Message Queue
4+ day, 5+ hour ago (1502+ words) [v0. 3. 0] - 2026-06-29 " Added Checkpoint Mechanism " Re Act Core introduces three checkpoints during streaming: content_ended (after text content), before_tool_calls (before tool calls), and after_tool_calls (after tool calls), enabling precise interception and state synchronization of the execution flow. Message Queue System " Added a new Message Queue class…...