Arricchimento del flusso asincrono con una coda di messaggi (ad esempio Kafka)

1

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.

    
posta Flow 15.11.2016 - 17:52
fonte

0 risposte

Leggi altre domande sui tag