conduktor.io ↗

KIP-1304 — Add consumer metric about paused partitions

Discussion ConsumerMetrics

Adds consumer metrics under consumer-coordinator-metrics tracking the number of currently paused partitions, which partitions are paused, how long they have been paused, and the rate of pause calls. The consumer exposes pause()/resume() for flow control and Kafka Streams uses it heavily for backpressure, post-rebalance task initialization, and changelog restore, yet no metric reveals pause state, so stuck consumers and buffer backpressure are invisible to monitoring.

Details

AuthorPoAn Yang
StatusDiscussion
JIRAKAFKA-18088
WikiView on Apache Wiki
Created2026-03-31
Last Modified2026-05-25
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.