Monitoring Consumer Group Lag
Inspect consumer group health with XINFO and XPENDING to measure lag, spot stuck consumers, and keep stream processing on track.
Why Monitor Lag?
In a healthy pipeline, consumers keep up with producers. When they fall behind, lag builds up: unread or unacknowledged entries pile in the stream. Monitoring lag lets you scale consumers before backlogs become outages.
Inspecting the Stream
XINFO STREAM gives a high-level view: length, last generated ID, and the number of consumer groups attached.
XINFO STREAM ordersAll lessons in this course
- Introduction to Consumer Groups
- Implementing Consumer Group Logic
- Handling Pending Messages & Failures
- Monitoring Consumer Group Lag