Rate

This plugin blocks messages after a certain number of messages per second has been reached.

Parameters

MessagesPerSec (default: 100)

This value defines the maximum number of messages per second allowed to pass through this filter. By default this parameter is set to “100”.

Ignore

Defines a list of streams that should not be affected by rate limiting. This is useful for e.g. producers listeing to “*”. By default this parameter is set to “empty”.

Parameters (from core.SimpleFilter)

FilteredStream

This value defines the stream filtered messages get sent to. You can disable this behavior by setting the value to “”. By default this parameter is set to “”.

Examples

This example accept ~10 messages in a second except the “noLimit” stream:

ExampleConsumer:
  Type: consumer.Console
  Streams: "*"
  Modulators:
    - filter.Rate:
      MessagesPerSec: 10
      Ignore:
        - noLimit