Mar 19, 2021
Using a combination of Kafka and Kafka Streams you can simplify this to a single topic with multiple partitions, as the other commenter said, and then create a Kafka Streams app that does the aggregation including with time windows. You could replace the Kafka Streams-based app with ksqlDb.