.map() și .mapValues() în Kafka Streams în Apache Kafka

Diferența critică între .map() și .mapValues()

În Kafka Streams, modificarea cheii unui mesaj determină automat necesitatea unei re-partiționări (re-keying) prin intermediul unui topic intern generat automat, implicând costuri de rețea și I/O pe disc.

• .mapValues(): Modifică exclusiv payload-ul mesajului lăsând cheia intactă. Nu generează repartiționare, fiind extrem de eficient.
• .map(): Poate modifica atât cheia cât și valoarea. Va forța repartiționarea automată dacă urmează operații de agregare sau join.

KStream<String, Utilizator> utilizatoriAnonimi = streamUtilizatori.mapValues(user -> {
    user.setParolaHash(null);
    user.setEmail(maskEmail(user.getEmail()));
    return user;
});