.aggregate() și .reduce() în Kafka Streams în Apache Kafka

Cum funcționează agregările stateful

Metodele aggregate() și reduce() gestionează starea continuă a aplicației (State Store) folosind o bază de date încorporată RocksDB și un topic intern de changelog pentru recuperare rapidă în caz de crash.

• .reduce(): Combină elementele de același tip (ex: însumarea a două valori numerice).
• .aggregate(): Permite ca tipul rezultatului agregat să fie complet diferit de tipul mesajului de intrare (ex: construirea unui profil complex dintr-un flux de evenimente simple).

KTable<String, Double> totalCheltuit = streamPlati
    .groupByKey()
    .aggregate(
        () -> 0.0, // Valoarea de start
        (clientId, plata, sumaTotala) -> sumaTotala + plata.getValoare(),
        Materialized.with(Serdes.String(), Serdes.Double())
    );