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