consumers

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

Overview

Name	consumers
Type	Resource
Id	confluent.kafka.consumers

Fields

Name	Datatype	Description
assignments	object
client_id	string
cluster_id	string
consumer_group_id	string
consumer_id	string
instance_id	string
kind	string
metadata	object

Methods

Name	Accessible by	Required Params	Description
get_kafka_consumer	SELECT	cluster_id, consumer_group_id, consumer_id	Return the consumer specified by the consumer_id.
list_kafka_consumers	SELECT	cluster_id, consumer_group_id	Return a list of consumers that belong to the specified consumer group.

SELECT examples

Return a list of consumers that belong to the specified consumer group.

SELECT
assignments,
client_id,
cluster_id,
consumer_group_id,
consumer_id,
instance_id,
kind,
metadata
FROM confluent.kafka.consumers
WHERE cluster_id = '{{ cluster_id }}'
AND consumer_group_id = '{{ consumer_group_id }}';