Apache Kafka ScramCredentialDelete

Apache Kafka ScramCredentialDelete

Certified

Delete a Kafka SCRAM user credential

Removes a SASL/SCRAM credential from a user using the Kafka AdminClient. This operation is destructive and cannot be undone.

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

Revoke a decommissioned tenant service account's credential

yaml
id: kafka_scram_credential_delete
namespace: company.team

tasks:
  - id: delete_credential
    type: io.kestra.plugin.kafka.ScramCredentialDelete
    properties:
      bootstrap.servers: localhost:9092
    user: tenant-acme-svc
    mechanism: SCRAM_SHA_512
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.

Username

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

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