5.10. トピックの削除
kafka-topics.sh ツールを使用してトピックを管理できます。kafka-topics.sh AMQ Streams ディストリビューションの一部で、bin ディレクトリーにあります。
前提条件
- AMQ Streams クラスターがインストールされ、実行されている。
-
トピック
mytopicが存在する。
トピックの削除
kafka-topics.shユーティリティーを使用してトピックを削除します。-
--bootstrap-serverオプションで、Kafka ブローカーのホストおよびポート。 -
--deleteオプションを使用して、既存のトピックを削除するように指定します。 トピック名は
--topicオプションで指定する必要があります。bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --delete --topic <TopicName>
bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --delete --topic <TopicName>Copy to Clipboard Copied! Toggle word wrap Toggle overflow という名前のトピックを作成するコマンドの例
mytopicbin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopic
bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopicCopy to Clipboard Copied! Toggle word wrap Toggle overflow
-
kafka-topics.shを使用してトピックが削除されていることを確認します。bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --list
bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --listCopy to Clipboard Copied! Toggle word wrap Toggle overflow すべてのトピックを一覧表示するコマンドの例
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
bin/kafka-topics.sh --bootstrap-server localhost:9092 --listCopy to Clipboard Copied! Toggle word wrap Toggle overflow
関連情報
- トピックの作成に関する詳細は、「トピックの作成」 を参照してください。