Apache Kafka TopicDelete

Apache Kafka TopicDelete
Certified
Delete one or more Kafka topics

Permanently deletes topics and all their data using the Kafka AdminClient. This operation is destructive and cannot be undone. Fails with UnknownTopicOrPartitionException if a topic does not exist.

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

Examples

Decommission tenant topics

yaml
id: kafka_topic_delete
namespace: company.team

tasks:
  - id: delete_topics
    type: io.kestra.plugin.kafka.TopicDelete
    properties:
      bootstrap.servers: localhost:9092
    topics:
      - tenant_acme_orders
      - tenant_acme_shipments

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.