#kafka-streams

2 posts.

Kafka Streams After 4.2: Two Changes That Make Failures Less Painful

Kafka Streams operations often hurt around bad records and rebalances. This post explains how DLQ support and the Streams Rebalance Protocol change the operating model after Kafka 4.2.

kafkakafka-streamsdlqrebalanceoperations

Kafka Streams and the EIP Aggregator: Finishing Is Harder Than Grouping

When implementing the EIP Aggregator pattern with Kafka Streams, the hard parts are not groupBy and aggregate. They are correlation keys, state stores, completion conditions, and late-event policy.

kafkakafka-streamseiparchitecturestream-processing