Skip to content

Commit 7efe5ba

Browse files
Merge pull request #302730 from spelluru/patch-514979
Consumer Lag in Event Hubs
2 parents bfbd3b3 + 65d0fb8 commit 7efe5ba

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

articles/event-hubs/monitor-event-hubs-reference.md

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
---
22
title: Monitoring data reference for Azure Event Hubs
33
description: This article contains important reference material you need when you monitor Azure Event Hubs by using Azure Monitor.
4-
ms.date: 06/20/2024
4+
ms.date: 07/14/2025
55
ms.custom: horz-monitor, subject-monitoring
66
ms.topic: reference
77
---
@@ -222,7 +222,7 @@ Application metrics logs capture the aggregated information on certain metrics r
222222
223223
| Name | Description |
224224
|:-------|:------- |
225-
| `ConsumerLag` |Indicate the lag between consumers and producers. The following governs the emission of consumer lag for Kafka consumers. A namespace is idle from Kafka offset commit point of view if there are no offset commits for any Kafka consumer group under the namespace. If namespace is idle for an hour, then we will stop emitting lag metrics. As long as namespace is not idle for offset commit, we will keep emitting metrics for all Kafka consumer groups under that namespace. If a namespace is non idle and the last offset commit for a consumer group predates the hub or topic's retention period, consumer lag will no longer be emitted. For AMQP consumers, consumer lag is emitted only as long as there are active receivers on the consumer group. |
225+
| `ConsumerLag` |Indicate the lag between consumers and producers. For more details, see [Consumer lag](#consumer-lag) section.|
226226
| `NamespaceActiveConnections` | Details of active connections established from a client to the event hub. |
227227
| `GetRuntimeInfo` | Obtain run time information from Event Hubs. |
228228
| `GetPartitionRuntimeInfo` | Obtain the approximate runtime information for a logical partition of an event hub. |
@@ -233,6 +233,14 @@ Application metrics logs capture the aggregated information on certain metrics r
233233
| `OffsetCommit` | Number of offset commit calls made to the event hub |
234234
| `OffsetFetch` | Number of offset fetch calls made to the event hub. |
235235

236+
#### Consumer lag
237+
238+
- The following points govern the emission of consumer lag for Kafka consumers.
239+
- A namespace is idle from Kafka offset commit point of view if there are no offset commits for any Kafka consumer group under the namespace.
240+
- If namespace is idle for an hour, then emission of lag metrics stops. As long as the namespace is not idle for offset commit, metrics are emitted for all Kafka consumer groups under that namespace.
241+
- If a namespace is non-idle and the last offset commit for a consumer group predates the hub or topic's retention period, consumer lag will no longer be emitted.
242+
- For AMQP consumers, consumer lag is emitted only as long as there are active receivers on the consumer group.
243+
236244
### Diagnostic Error Logs
237245

238246
Diagnostic error logs capture error messages for any client side, throttling, and Quota exceeded errors. They provide detailed diagnostics for error identification.

0 commit comments

Comments
 (0)