5.10. トピックの削除

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

前提条件

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

トピックの削除

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

    • --zookeeper オプションで ZooKeeper の URL を指定します。
    • --delete オプション: 既存のトピックを削除することを指定するのに使用します。
    • --topic オプションでトピック名を指定する必要があります。

      bin/kafka-topics.sh --zookeeper  <ZooKeeperAddress> --delete --topic <TopicName>

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

      bin/kafka-topics.sh --zookeeper zoo1.my-domain.com:2181 --delete --topic mytopic

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

    bin/kafka-topics.sh --zookeeper  <ZooKeeperAddress> --list

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

    bin/kafka-topics.sh --zookeeper zoo1.my-domain.com:2181 --list

関連情報