Apache Kafka QuotaDescribe

Apache Kafka QuotaDescribe

Certified

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.

yaml
type: io.kestra.plugin.kafka.QuotaDescribe

Inspect the quotas applied to a tenant service account

yaml
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

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.

Client ID entity name

IP entity name

User entity name

Reference (ref) of the pluginDefaults to apply to this task.

DefaultPT30S

AdminClient call timeout

Maximum duration to wait for each AdminClient operation to complete before failing the task. Defaults to PT30S (30 seconds).

SubTypeobject

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).