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