kafka削除メッセージ

2173 ワード
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
    Ext 4ノート
    HDU-A-Oulipo【ボードライブラリ_KMPアルゴリズム】