5.10. トピックの削除

kafka-topics.sh ツールを使用してトピックを管理できます。kafka-topics.sh AMQ Streams ディストリビューションの一部で、bin ディレクトリーにあります。

前提条件

  • AMQ Streams クラスターがインストールされ、実行されている。
  • トピック mytopic が存在する。

トピックの削除

  1. kafka-topics.sh ユーティリティーを使用してトピックを削除します。

    • --bootstrap-server オプションで、Kafka ブローカーのホストおよびポート。
    • --delete オプションを使用して、既存のトピックを削除するように指定します。

    • トピック名は --topic オプションで指定する必要があります。 

      bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --delete --topic <TopicName>

      という名前のトピックを作成するコマンドの例 mytopic

      bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopic

  2. kafka-topics.sh を使用してトピックが削除されていることを確認します。 

    bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --list

    すべてのトピックを一覧表示するコマンドの例

    bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

関連情報