consumers_lags

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

Overview

Name	consumers_lags
Type	Resource
Id	confluent.kafka.consumers_lags

Fields

Name	Datatype	Description
client_id	string
cluster_id	string
consumer_group_id	string
consumer_id	string
current_offset	integer
instance_id	string
kind	string
lag	integer
log_end_offset	integer
metadata	object
partition_id	integer
topic_name	string

Methods

Name	Accessible by	Required Params	Description
get_kafka_consumer_lag	SELECT	cluster_id, consumer_group_id, partition_id, topic_name	Return the consumer lag on a partition with the given partition_id.
list_kafka_consumer_lags	SELECT	cluster_id, consumer_group_id	Return a list of consumer lags of the consumers belonging to the specified consumer group.

SELECT examples

Return a list of consumer lags of the consumers belonging to the specified consumer group.

SELECT
client_id,
cluster_id,
consumer_group_id,
consumer_id,
current_offset,
instance_id,
kind,
lag,
log_end_offset,
metadata,
partition_id,
topic_name
FROM confluent.kafka.consumers_lags
WHERE cluster_id = '{{ cluster_id }}'
AND consumer_group_id = '{{ consumer_group_id }}';