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

Defined in:

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

Overview

Active refreshing of watermarks and lags for long-paused partitions. librdkafka only updates those values from fetch responses, so partitions paused for a long time report frozen statistics. The refresher periodically fetches fresh values via the running consumer connection and the decorator overlays them onto the emitted statistics.

Defined Under Namespace

Classes: Compensator, Fetcher, Refresher, Registry