Module: Karafka::Callbacks

Defined in:: lib/karafka/callbacks.rb,
lib/karafka/callbacks/dsl.rb,
lib/karafka/callbacks/config.rb

Overview

Note:

Those callbacks aren’t the same as consumer callbacks as they are not related to the lifecycle of particular messages fetches but rather to the internal flow process. They cannot be defined on a consumer callback level because for some of those, there aren’t consumers in the memory yet and/or they aren’t per consumer thread

Additional callbacks that are used to trigger some things in given places during the system lifecycle

Defined Under Namespace

Modules: Config, Dsl

Constant Summary collapse

TYPES = Types of system callbacks that we have that are not related to consumers

%i[
  after_init
  before_fetch_loop
].freeze