consumer_groups

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

Overview

Name	consumer_groups
Type	Resource
Id	confluent.kafka.consumer_groups

Fields

Name	Datatype	Description
cluster_id	string
consumer	object
consumer_group_id	string
coordinator	object
is_simple	boolean
kind	string
lag_summary	object
metadata	object
partition_assignor	string
state	string

Methods

Name	Accessible by	Required Params	Description
get_kafka_consumer_group	SELECT	cluster_id, consumer_group_id	Return the consumer group specified by the consumer_group_id.
list_kafka_consumer_groups	SELECT	cluster_id	Return the list of consumer groups that belong to the specified Kafka cluster.

SELECT examples

Return the list of consumer groups that belong to the specified Kafka cluster.

SELECT
cluster_id,
consumer,
consumer_group_id,
coordinator,
is_simple,
kind,
lag_summary,
metadata,
partition_assignor,
state
FROM confluent.kafka.consumer_groups
WHERE cluster_id = '{{ cluster_id }}';