Module: Karafka::Pro::Processing::Filters

Defined in:

lib/karafka/pro/processing/filters/throttler.rb,
lib/karafka/pro/processing/filters/base.rb,
lib/karafka/pro/processing/filters/delayer.rb,
lib/karafka/pro/processing/filters/expirer.rb,
lib/karafka/pro/processing/filters/virtual_limiter.rb

Overview

Namespace containing Pro out of the box filters used by various strategies

Defined Under Namespace

Classes: Base, Delayer, Expirer, Throttler, VirtualLimiter