akka/akka-core

add possibility to BroadcastHub to retry last N records for every new consumer

Aperta

#23.816 aperta il 17 ott 2017

Vedi su GitHubGuida contributor
 (1 commento) (0 reazioni) (0 assegnatari)Scala (3547 fork)batch import
3 - in progresshelp wantedt:stream

Metriche repository

Star
 (13.277 stelle)
Metriche merge PR
 (Merge medio 8g 19h) (10 PR mergiate in 30 g)

Descrizione

BroadcastHub is a class to create a sink for a dynamic set of consumers. In my case speed of data publishing is not so fast and I should retry last N records to every new consumer, so users will see records in any time.

Guida contributor

Direzione di ricerca
Studia l'implementazione di BroadcastHub in Akka Streams, comprendi come gestisce i consumatori e i buffer, quindi progetta un meccanismo per riprodurre gli ultimi N record per ogni nuovo consumatore.
Tech stack
scala
Dominio
backend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
3-5 giorni
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Datata
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
ScalaAkkaAkka Streams
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
40