Apache Kafka ConsumerGroupList
CertifiedList Kafka consumer groups
Apache Kafka ConsumerGroupList
Certified
List Kafka consumer groups
Lists every consumer group known to the cluster, with its state, using the Kafka AdminClient.
yaml
type: io.kestra.plugin.kafka.ConsumerGroupListExamples
List all consumer groups
yaml
id: kafka_consumer_group_list
namespace: company.team
tasks:
- id: list_groups
type: io.kestra.plugin.kafka.ConsumerGroupList
properties:
bootstrap.servers: localhost:9092
Properties
properties *Requiredobject
Kafka AdminClient properties
Must include bootstrap.servers; accepts any Kafka AdminClient config. Provide base64-encoded content for ssl.keystore.location and ssl.truststore.location when using SSL.
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
timeout string
Default
PT30SAdminClient call timeout
Maximum duration to wait for each AdminClient operation to complete before failing the task. Defaults to PT30S (30 seconds).
Outputs
groups array
SubTypeobject
Consumer groups
Each entry contains groupId, isSimpleConsumerGroup and state.
