Deleting a Kafka Topic

Prerequisites

• A Kafka instance has been created, and a topic has been created in this instance.
• The Kafka instance is in the Running state.

Constraints

If your Kafka instances are connected using Logstash, stop Logstash before deleting topics. Otherwise, services may crash.

Deleting a Kafka Topic (Console)

1. Log in to the console.
2. Click in the upper left corner to select a region.
   

   Select the region where your Kafka instance is located.

3. Click and choose Application > Distributed Message Service for Kafka to open the console of DMS for Kafka.
4. Click the desired Kafka instance to view the instance details.
5. In the navigation pane, choose Topics.
6. Delete topics using either of the following methods:
   • Select one or more topics and click Delete Topic in the upper left corner.
   • In the row containing the topic you want to delete, choose More > Delete.

7. In the Delete Topic dialog box that is displayed, click OK to delete the topic.

Deleting a Kafka Topic on the Client

If your Kafka client version is later than 2.2, you can use kafka-topics.sh to delete topics.

For an instance with SASL enabled, if allow.everyone.if.no.acl.found is set to false, topics cannot be deleted through the client.

• If SASL is not enabled for the Kafka instance, run the following command in the /{directory where the CLI is located}/kafka_{version}/bin/ directory to delete a topic:

  ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --delete --topic {topic_name}

• If SASL has been enabled for the Kafka instance, perform the following steps to delete a topic:
  1. (Optional) If the SSL certificate configuration has been set, skip this step. Otherwise, perform the following operations:

     Create the ssl-user-config.properties file in the /config directory of the Kafka client and add the SSL certificate configurations by referring to 3.

  2. Run the following command in the /{directory where the CLI is located}/kafka_{version}/bin/ directory to delete a topic:

     ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --delete --topic {topic_name} --command-config ./config/ssl-user-config.properties