DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: DraftUnder Discussion
Discussion thread: https://lists.apache.org/thread/z4o5093zqxmc18nzb74vyhvb1hb399v4
JIRA:
| Jira | ||||||
|---|---|---|---|---|---|---|
|
...
- How many partitions are currently paused? A high number of paused partitions may indicate backpressure issues, slow state restoration, or application-level processing bottlenecks.
- Which specific partitions are paused? Knowing which partitions are paused helps pinpoint which topics or partitions are experiencing issues.
- How long has a partition been paused? A partition that has been paused for an extended period may indicate a stuck consumer, an unrecoverable error in processing, or a state store restoration that is taking too long.
...
The metric will have the following tags:
- client-id
| Metric Name | Type | Recording Level | Description |
| paused-partitions-count | Gauge (Integer) | INFO | The current number of partitions that have been paused by the user via `Consumer.pause()`. |
consumer-fetch-manager-metrics
Each metric will have the following tags:
- client-id
- topic
- partition
| Metric Name | Type | Recording Level | Description |
| partition-paused | Gauge (Integer) | DEBUG | Whether this partition is currently paused. Returns `1` if paused, `0` if not paused. |
| partition-paused-time-ms | Gauge (Long) | DEBUG | The time in milliseconds since this partition was paused. Returns `0` if the partition is not currently paused. |
Proposed Changes
Track Pause Timestamp
...