Streaming & Queues

Event streaming, pub/sub, backpressure, and consumer groups at scale.

  • 6 Tracked terms
  • Last 30 days Feed window

What this topic collects on

An article joins this feed when it matches these terms. Each one is also a search of its own.

Latest in Streaming & Queues


dev.to > nazrinsuleymanli > stop-chasing-exactly-once-your-kafka-consumer-just-needs-to-not-care-1j5m

Stop Chasing Exactly-Once. Your Kafka Consumer Just Needs to Not Care

13+ hour, 44+ min ago   (368+ words) Every few months a team I talk to decides they need exactly-once delivery in Kafka. They read the... Tagged with java, microservices, kafka, springboot....


dev.to > nazrinsuleymanli > your-kafka-consumer-will-see-every-event-twice-heres-how-to-handle-it-1phk

Your Kafka Consumer Will See Every Event Twice - Here's How to Handle It

1+ day, 12+ hour ago   (781+ words) In this tutorial, we'll fix that assumption: why duplicates are normal, why the obvious consumer code fails silently, and how to make a Spring Boot Kafka consumer idempotent - safe to run any number of times with the same result as…...


dzone.com > articles > mcp-vs-resthttp-api-vs-kafka

MCP vs REST/HTTP API vs Kafka

2+ day, 9+ hour ago   (1319+ words) MCP, Kafka, and REST APIs are not the same: this comparison maps each to the right layer of your agentic AI architecture. These three technologies can and do coexist in the same architecture. The question is not which one to…...


dev.to > hermespimentel > share-groups-no-apache-kafka-kip-932-o-que-sao-como-funcionam-e-o-que-exigem-na-pratica-1hm2

Share Groups no Apache Kafka (KIP-932): o que são, como funcionam e o que exigem na prática

2+ day, 14+ hour ago   (1193+ words) Share Groups ("Queues for Kafka"), definidos no KIP-932 (Kafka Improvement Proposal 932), são um... Tagged with distributedsystems, kafka, streaming, dataengineering....


dev.to > seatunnel > how-apache-seatunnel-handles-kafka-topic-partition-expansion-without-a-job-restart-44a0

How Apache SeaTunnel Handles Kafka Topic Partition Expansion Without a Job Restart

2+ day, 19+ hour ago   (271+ words) 1. Scenario When using an Apache SeaTunnel streaming job to consume data from a Kafka... Tagged with apacheseatunnel, kafka, beginners, datascience....


dev.to > akincskn > why-i-used-kafka-for-a-small-incident-management-tool-2683

Why I Used Kafka for a Small Incident Management Tool

2+ day, 21+ hour ago   (808+ words) TL;DR I built OpsFlow, an incident management SaaS for small ops teams: log incidents, assign severity, track SLA deadlines, and notify the right people in real time. Under the hood it's a microservice setup (API, frontend, and a separate…...


dzone.com > articles > kafka-complements-autonomous-agents

Event-Driven AI Systems With Kafka and Autonomous Agents

4+ day, 12+ hour ago   (270+ words) Enterprise AI is moving beyond isolated prompt-response calls and toward systems that observe events, preserve state, invoke tools, and publish decisions back into operational workflows. In that setting, event streaming is not simply middleware. It becomes the record of how…...


dev.to > kary_0009 > event-sourcing-trying-out-sekiban-dcb-implementation-2076

[Event Sourcing] Trying out Sekiban DCB: Implementation

4+ day, 23+ hour ago   (414+ words) Introduction This article is a continuation of "[Event Sourcing] Trying out Sekiban DCB:... Tagged with eventsourcing, tutorial, dcb....


medium.com > @jrkrish82 > ordering-guarantees-at-scale-the-sequential-convoy-pattern-in-java-and-kafka-8d2962585981

Ordering Guarantees at Scale: The Sequential Convoy Pattern in Java and Kafka

4+ day, 20+ hour ago   (1341+ words) The Sequential Convoy pattern for strict event sequencing in Java, Kafka, and IBM MQ A portfolio accounting system once …...


dev.to > kary_0009 > event-sourcing-trying-out-sekiban-dcb-introduction-4m78

[Event Sourcing] Trying out Sekiban DCB: Introduction

5+ day, 1+ hour ago   (18+ words) Introduction While researching ways to ensure data consistency using NoSQL in systems with... Tagged with tutorial, eventsourcing, dcb....