Apache Kafka QuotaDescribe
CertifiedDescribe Kafka client quotas
Apache Kafka QuotaDescribe
Describe Kafka client quotas
Lists client quotas (producer_byte_rate, consumer_byte_rate, request_percentage, controller_mutation_rate) matching an entity filter using the Kafka AdminClient.
Describes every quota on the cluster when no entity filter is set.
type: io.kestra.plugin.kafka.QuotaDescribeExamples
Inspect the quotas applied to a tenant service account
id: kafka_quota_describe
namespace: company.team
tasks:
- id: describe_quota
type: io.kestra.plugin.kafka.QuotaDescribe
properties:
bootstrap.servers: localhost:9092
entityUser: tenant-acme-svc
Properties
properties *object
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.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150callTimeout string
PT30SAdminClient call timeout
Maximum duration to wait for each AdminClient operation to complete before failing the task. Defaults to PT30S (30 seconds). Distinct from the task-level timeout, which lets the worker kill the task without retrying it.
entityClientId string
Client ID entity name
entityIp string
IP entity name
entityUser string
User entity name
Outputs
quotas array
Matching quota entities
Each entry contains entity (keys among user, client-id, ip) and quotas (keys among producer_byte_rate, consumer_byte_rate, request_percentage, controller_mutation_rate).
