akka/akka-core

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

Aberta

#23.816 aberto em 17 de out. de 2017

Ver no GitHubGuia do colaborador
 (1 comentário) (0 reação) (0 responsável)Scala (3.547 forks)batch import
3 - in progresshelp wantedt:stream

Métricas do repositório

Stars
 (13.277 estrelas)
Métricas de merge de PR
 (Mesclagem média 8d 19h) (10 fundiu PRs em 30d)

Description

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.

Guia do colaborador

Direção de pesquisa
Estude a implementação do BroadcastHub no Akka Streams, entenda como ele gerencia consumidores e buffers, e então projete um mecanismo para reproduzir os últimos N registros para novos consumidores.
Pilha de tecnologia
scala
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
3-5 dias
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Antigo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
ScalaAkkaAkka Streams
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
40