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.

topics *array

SubTypestring

Topics to delete

pluginDefaultsRef string

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

timeout string

DefaultPT30S

AdminClient call timeout

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

Outputs

deletedTopics array

SubTypestring

Topics that were deleted

Liquibase

Tasks that run Liquibase change management commands.

Data

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

Apache Kafka TopicDeleteCertifiedDelete one or more Kafka topics

Apache Kafka TopicDelete

More Plugins in this Category

Liquibase

PostgreSQL

Apache Kafka TopicDelete
Certified
Delete one or more Kafka topics