Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Metric NameTypeDescription
paused-partitionsGauge (Integer)The current number of partitions that have been paused by the user via Consumer.pause() .
paused-partitions-rateRateThe per-second rate of Consumer.pause()  calls.
paused-partitions-totalCumulativeCountThe total cumulative number of Consumer.pause()  calls.
paused-partitions-max-duration-max-secondsGauge (Long)The maximum duration in seconds that any partition has been paused. Returns -1 if no partition is currently paused.

...

Currently, each partition's internal state tracks whether it is paused with a simple boolean flag. To support the paused-partitions-duration-seconds  metric, this KIP adds a timestamp that records when the partition was paused. The timestamp is set when pause()  is called, cleared (reset to -1) when resume() is called, and also reset to -1 cleared on partition reassignment regardless of prior pause status. This ensures that a partition re-assigned to the same consumer after a rebalance starts with a clean pause state.

...