kafka削除メッセージ

削除可能なダイレクトコマンドが設定されている場合は削除

コンフィギュレーション
server.properties
delete.topic.enable=true

# test
kafka-topics  --delete --zookeeper hs01:2181  --topic test

zookeeperクライアント削除

# 
./zookeeper-shell.sh hs01:2181

# 
rmr /brokers/topics/test
rmr /admin/delete_topics/test

kafkaログ削除

ログディレクトリの検索

kafka
############################# Log Basics #############################

# A comma seperated list of directories under which to store log files
log.dirs=/opt/rt/kafka/kafka-logs

# 
rm -rf /opt/rt/kafka/kafka-logs/test-0