Vorrei arricchire alcuni dati di streaming, con un servizio per arricchimento, possibilmente ciascun servizio scritto in una lingua diversa e gestito / distribuito separatamente.
Ogni servizio consumerebbe qualche argomento di Kafka, arricchirà il messaggio e lo pubblicherà in alcuni argomenti di Kafka.
Alla fine, avrei un argomento di messaggi completamente arricchiti.
Idealmente, alcuni dei passaggi sarebbero fatti contemporaneamente, ma questo non è un requisito.
Quali sono i framework, i protocolli o i pattern che corrispondono a questo tipo di casi d'uso? Per me assomiglia ai normali servizi micro asincroni, ma con alto rischio di accoppiamento tra i servizi.