Apache Kafka ScramCredentialCreate

Apache Kafka ScramCredentialCreate

Certified

Create or update a Kafka SCRAM user credential

Upserts a SASL/SCRAM credential for a user using the Kafka AdminClient, typically to provision a per-tenant service account.

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

Provision a SCRAM credential for a tenant service account

yaml
id: kafka_scram_credential_create
namespace: company.team

tasks:
  - id: create_credential
    type: io.kestra.plugin.kafka.ScramCredentialCreate
    properties:
      bootstrap.servers: localhost:9092
    user: tenant-acme-svc
    password: "{{ secret('TENANT_ACME_KAFKA_PASSWORD') }}"
    mechanism: SCRAM_SHA_512
Properties

Password

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.

Username

Default4096

Iteration count

Number of SCRAM hashing iterations, between 4096 and 16384. Defaults to 4096.

DefaultSCRAM_SHA_512
Possible Values
SCRAM_SHA_256SCRAM_SHA_512

SCRAM mechanism

Defaults to SCRAM_SHA_512.

DefaultPT30S

AdminClient call timeout

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

Iteration count

Possible Values
SCRAM_SHA_256SCRAM_SHA_512

SCRAM mechanism

Username

More Plugins in this Category

Prefect
Prefect

Tasks that trigger Prefect deployments and monitor flow runs.

Data

1 tasks

1 blueprints

Azure (EE)
Azure
Enterprise

Tasks that integrate Microsoft Azure services into Kestra enterprise workflows.

CloudDataInfrastructure

7 tasks