consumers_lag_summary

Creates, updates, deletes, gets or lists a consumers_lag_summary resource.

Overview

Name	consumers_lag_summary
Type	Resource
Id	confluent.kafka.consumers_lag_summary

Fields

Name	Datatype	Description
cluster_id	string
consumer_group_id	string
kind	string
max_lag	integer
max_lag_client_id	string
max_lag_consumer	object
max_lag_consumer_id	string
max_lag_instance_id	string
max_lag_partition	object
max_lag_partition_id	integer
max_lag_topic_name	string
metadata	object
total_lag	integer

Methods

Name	Accessible by	Required Params	Description
get_kafka_consumer_group_lag_summary	SELECT	cluster_id, consumer_group_id	Return the maximum and total lag of the consumers belonging to the specified consumer group.

SELECT examples

Return the maximum and total lag of the consumers belonging to the specified consumer group.

SELECT
cluster_id,
consumer_group_id,
kind,
max_lag,
max_lag_client_id,
max_lag_consumer,
max_lag_consumer_id,
max_lag_instance_id,
max_lag_partition,
max_lag_partition_id,
max_lag_topic_name,
metadata,
total_lag
FROM confluent.kafka.consumers_lag_summary
WHERE cluster_id = '{{ cluster_id }}'
AND consumer_group_id = '{{ consumer_group_id }}';