Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

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

Open
sergei-grigorev opened this issue Oct 17, 2017 · 1 comment
Open

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

sergei-grigorev opened this issue Oct 17, 2017 · 1 comment
Labels
3 - in progress Someone is working on this ticket help wanted Issues that the core team will likely not have time to work on t:stream

Comments

@sergei-grigorev
Copy link

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.
@sergei-grigorev
Copy link
Author

sergei-grigorev commented Oct 17, 2017 •
edited

I've done this with a little excluding: in case the upstream is closed BroadcastHub also closes. It completely enough for my case cause I have infinitive streams which could be stopped with KillSwitch.

I have a little problem with making it work for the finished stream. But I don't know if this case will be interesting for someone, to fix it right now.

sergei-grigorev pushed a commit to sergei-grigorev/akka that referenced this issue Oct 18, 2017
add possibility to BroadcastHub to retry last N records for every new…
211a3e3 
… consumer akka#23816

* add new field to BroadcastHub to work with retry
* add unit test to check new feature
* update documentation to show this feature
@sergei-grigorev sergei-grigorev mentioned this issue Oct 18, 2017
Closed
@ktoso ktoso added 3 - in progress Someone is working on this ticket help wanted Issues that the core team will likely not have time to work on t:stream labels Oct 23, 2017
sergei-grigorev pushed a commit to sergei-grigorev/akka that referenced this issue Dec 14, 2017
add possibility to BroadcastHub to retry last N records for every new…
83c0b36 
… consumer akka#23816

* add new field to BroadcastHub to work with retry
* add unit test to check new feature
* update documentation to show this feature
sergei-grigorev pushed a commit to sergei-grigorev/akka that referenced this issue Dec 14, 2017
add possibility to BroadcastHub to retry last N records for every new…
3a19758 
… consumer akka#23816

* add new field to BroadcastHub to work with retry
* add unit test to check new feature
* update documentation to show this feature
sergei-grigorev pushed a commit to sergei-grigorev/akka that referenced this issue Dec 14, 2017
add possibility to BroadcastHub to retry last N records for every new…
f689744 
… consumer akka#23816

* add new field to BroadcastHub to work with retry
* add unit test to check new feature
* update documentation to show this feature
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
3 - in progress Someone is working on this ticket help wanted Issues that the core team will likely not have time to work on t:stream
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@ktoso @sergei-grigorev