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.

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

Think next steps around guarantees and performance #242

Open
michal-harish opened this issue Aug 24, 2018 · 0 comments
Open

Think next steps around guarantees and performance #242

michal-harish opened this issue Aug 24, 2018 · 0 comments

Comments

@michal-harish
Copy link
Member

michal-harish commented Aug 24, 2018

  • we already have a general at-least-once processing which a good foundation
  • batching sends at the akka level should be given a though first in case it constraints this one
  • exactly-once would be nice but
    1. going the route of deduplication in-memory sets is general but is a big hit on throughput and memory
    2. going the route of kafka transactions performs well but is not general, i.e:
      a) it will only work with kafka as a log storage (not a problem as long as the implementation doesn't prescribe kafka even if exactly-once is not required)
      b) kafka transactions work only on the same cluster which is acceptable
    3. is there a third way ?

In some other design work related to commits there were 2 points considered:
a) being able to do flushAll() on or produce operations
b) have a global context of all operations, i.e. their futures, which were executed

@michal-harish michal-harish changed the title Think next steps around guarantees Think next steps around guarantees and performance Aug 24, 2018
@michal-harish michal-harish added this to the performance milestone Aug 24, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant