kubernetesでkafkaのtopicを削除する

やったことを忘れないようにメモ代わりです。
前提として、すでにkafkaがkubernetesのpodで動いているとして話をすすめます。

kafkaのpodに入る

$ kubectl exec -it kafka-0 -- /bin/bash

でpod上のkafkaに入れます。

topicの一覧

$ kafka-topics.sh --list --bootstrap-server kafka-0:9092

でtopicの一覧が出てくる

例:

bash-4.4# kafka-topics.sh --list --bootstrap-server kafka-0:9092
__consumer_offsets
js_eval.requests
tb_rule_engine
tb_transport.api.requests
tb_transport.api.responses.tb-http-transport-68bcd57cf8-xrt6j
tb_transport.notifications.tb-http-transport-68bcd57cf8-xrt6j

bootstrap-serverは/opt/kafka/config/producer.propertiesに記載がある。

############################# Producer Basics #############################

# list of brokers used for bootstrapping knowledge about the rest of the cluster
# format: host1:port1,host2:port2 ...
bootstrap.servers=localhost:9092

topicの削除

$ kafka-topics.sh --delete --bootstrap-server kafka-0:9092 --topic トピック名

で削除することができる。

bannerAds