topic_partitions

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

Overview

Name	topic_partitions
Type	Resource
Id	confluent.kafka.topic_partitions

Fields

Name	Datatype	Description
cluster_id	string
kind	string
leader	object
metadata	object
partition_id	integer
reassignment	object
replicas	object
topic_name	string

Methods

Name	Accessible by	Required Params	Description
get_kafka_partition	SELECT	cluster_id, partition_id, topic_name	Return the partition with the given partition_id.
list_kafka_partitions	SELECT	cluster_id, topic_name	Return the list of partitions that belong to the specified topic.

SELECT examples

Return the list of partitions that belong to the specified topic.

SELECT
cluster_id,
kind,
leader,
metadata,
partition_id,
reassignment,
replicas,
topic_name
FROM confluent.kafka.topic_partitions
WHERE cluster_id = '{{ cluster_id }}'
AND topic_name = '{{ topic_name }}';