dovresti essere in grado di risolvere il problema usando Kafka Streams - in un modo simile (semplificato) come in questo caso https://debezium.io/blog/2018/03/08/creating-ddd-aggregates-with-debezium-and-kafka-streams /
dovresti essere in grado di risolvere il problema usando Kafka Streams - in un modo simile (semplificato) come in questo caso https://debezium.io/blog/2018/03/08/creating-ddd-aggregates-with-debezium-and-kafka-streams /