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

Defined in:

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

Overview

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

Defined Under Namespace

Classes: Base, Delayer, Expirer, InlineInsightsDelayer, Throttler, VirtualLimiter