7.10. トピックの削除
kafka-topics.sh ツールを使用してトピックを管理できます。kafka-topics.sh は、Streams for Apache Kafka ディストリビューションの一部であり、bin ディレクトリーにあります。
前提条件
- Streams for Apache Kafka が 各ホストにインストールされており、設定ファイルが使用可能である。
トピックの削除
kafka-topics.shユーティリティーを使用してトピックを削除します。-
--bootstrap-serverにおける Kafka ブローカーのホストおよびポート。 -
--deleteオプション: 既存のトピックを削除することを指定するために使用します。 --topicオプション: このオプションでトピック名を指定する必要があります。/opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_host>:<port> --delete --topic <topic_name>
mytopicというトピックを作成するコマンドの例/opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopic
-
kafka-topics.shを使用して、トピックが削除されたことを確認します。/opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_host>:<port> --list
すべてのトピックをリスト表示するコマンドの例
/opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
