Class: Karafka::Pro::Routing::Features::Delaying

Inherits:
Base show all
Defined in:
lib/karafka/pro/routing/features/delaying.rb,
lib/karafka/pro/routing/features/delaying/topic.rb,
lib/karafka/pro/routing/features/delaying/config.rb,
lib/karafka/pro/routing/features/delaying/contracts/topic.rb

Overview

Delaying allows us to delay processing of certain topics. This is useful when we want to for any reason to wait until processing data from a topic. It does not sleep and instead uses pausing to manage delays. This allows us to free up processing resources and not block the polling thread.

Delaying is a virtual feature realized via the filters

Defined Under Namespace

Modules: Contracts, Topic Classes: Config

Method Summary

Methods inherited from Routing::Features::Base

activate, load_all, post_setup_all, pre_setup_all