você deve conseguir resolver o problema usando o Kafka Streams - de maneira semelhante (simplificada) como neste caso https://debezium.io/blog/2018/03/08/creating-ddd-aggregates-with-debezium-and-kafka-streams /