Module: Karafka::Pro::Instrumentation::ConsumerGroups

Defined in:

lib/karafka/pro/instrumentation/consumer_groups/lag_compensation/fetcher.rb,
lib/karafka/pro/instrumentation/consumer_groups/lag_compensation/registry.rb,
lib/karafka/pro/instrumentation/consumer_groups/lag_compensation/refresher.rb,
lib/karafka/pro/instrumentation/consumer_groups/lag_compensation/compensator.rb

Overview

Instrumentation components for consumer groups based operation

Defined Under Namespace

Modules: LagCompensation