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

Sink Buffer #4

Open

marceloboeira opened this issue May 22, 2019 · 0 comments

Owner

marceloboeira commented May 22, 2019

Add support to a sink buffer, to avoid round-trips on every incoming request.

The buffer should be configurable through the configuration file: #3.

The buffer should have a configurable timeout too, something like, "100 messages OR 1 second" and it could be adjustable per sink.

routes:
  - path: "/foo"
    sink: 
      adapter: redis
      uri: "redis://[USER]:[PASSWORD]@[IP]:[PORT]"
      buffer:
        size: 100
        timeout: 1s

document that sink buffers are volatile and shouldn't be used for situations that there is no tolerance for message dropping.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment