Promhub Logo Prom hub

Kafka consumer lag
warning

Description Kafka consumer has a 30 minutes and increasing lag
Query for 15m 
>>>
	
				
					
				
			
				
					 - on(partition, cluster, topic) group_right() 
				
			
				
					
				
			
				
					 >= (
				
			
				
					
				
			
				
					 offset 15m - on(partition, cluster, topic) group_right() 
				
			
				
					
				
			
				
					 offset 15m) AND 
				
			
				
					
				
			
				
					 - on(partition, cluster, topic) group_right() 
				
			
				
					
				
			
				
					 > 0
Query Explanation

The rule checks the consumer lag for each Kafka partition (latest offset minus current consumer offset) and fires when the lag is positive and has increased compared to its value 15 minutes ago, indicating a growing lag over a 30‑minute period.

Get Alert✕
Download
Copy to Clipboard