Class: Karafka::Pro::Routing::Features::Expiring

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

Overview

Expiring allows us to filter out messages that are older than our expectation. This can also be done in a consumer, but applying the filtering prior to the jobs enqueuing allows us to improve operations with virtual partitions and limit the number of not necessary messages being ever seen

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