Domande con tag 'apache-kafka'

domande con tag
1
risposta

Come posso gestire il multiproduttore a un particolare utente singolo in Kafka?

Sto valutando il Kafka. Fornisce alcune caratteristiche interessanti che desidero utilizzare, in particolare la durata predefinita e l'accesso ai messaggi precedenti per i nuovi consumatori, ogni volta che il consumatore desidera raggiungere qua...
posta 03.10.2017 - 14:00
1
risposta

Costruire un'API in tempo reale su una struttura Kafka / Kinesis-centrica

Sono un principiante dell'architettura dei dati basata su eventi che usa Kafka / Kinesis come fulcro (attualmente Kinesis) e ho alcune domande su come costruire un'API WebSocket su tale struttura. Il mio caso d'uso specifico è che ho circa 4 div...
posta 19.03.2018 - 02:45
2
risposte

Come creare un'API scalabile, containerizzabile e gestibile con GraphQL, Kafka, Docker, Kubernetes e MongoDB?

Non ho dubbi riguardo a cosa fa ciascuna tecnologia. Ho provato anche tutti loro. Quello di cui dubito è: Nel caso utilizziamo GraphQL, non agirà come un singolo punto di errore se il server GraphQL non funziona? Può essere raggruppato in clu...
posta 05.01.2018 - 14:45
1
risposta

# Apache-flink: elaborazione stream o elaborazione batch tramite Flink

Ho il compito di ridisegnare un processore di catalogo esistente e il requisito è il seguente Requisiti Ho da 5 a 10 fornitori (ogni venditore può avere più negozi) che mi fornirebbe un file 'XML' per negozio. In pratica, 1 file xml di prodott...
posta 22.09.2016 - 08:11
0
risposte

Apache Spark guidance - Può fare ciò di cui ho bisogno?

Stiamo lavorando su una grande piattaforma di microservizi per un'azienda nel settore degli eventi dal vivo. È costituito da API RESTful containerizzate, per lo più costruite in Nodo, che lavorano con Apache Kafka e Cassandra sul back-end. Oltre...
posta 08.10.2018 - 21:43
4
risposte

Architettura di applicazioni Web per app in tempo reale

Usecase : l'utente finale effettua un ordine sul sito Web dell'azienda, l'ordine deve essere trasferito alla schermata dell'amministratore dell'azienda con una piccola latenza. La società ha più filiali (identificate dalla combinazione compId e...
posta 26.01.2017 - 02:04
0
risposte

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

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, arricchi...
posta 15.11.2016 - 17:52
2
risposte

Invia lavori pesanti di calcolo dal server web a un altro processo e attendi la risposta

So che è prassi comune inviare task pesanti con controllo della cpu ai processi in background, al fine di liberare un server web per servire altre richieste. Ma - cosa succede se la richiesta deve conoscere il risultato di tale calcolo? Esist...
posta 04.02.2015 - 23:34
1
risposta

Elaborazione solo dopo lo stesso messaggio prodotto da due produttori

Se ho due produttori diversi che potrebbero produrre lo stesso messaggio per un broker Kafka, come posso garantire che solo una delle due occorrenze del messaggio venga elaborata? È l'unico modo per avere un argomento di input, quindi un cons...
posta 06.09.2018 - 11:57
1
risposta

Valuta i reqre http e i websocket per le trasmissioni basate sulla geolocalizzazione

Il mio caso di utilizzo è che ho un'app di trasmissione in tempo reale in cui gli utenti ricevono elementi di feed basati su una geolocalizzazione, ovvero un utente riceverà post trasmessi da un raggio definito dall'utente in cui risiede attualm...
posta 27.05.2018 - 14:51