1.在zookeeper安裝目錄下執行以下命令進入zookeeper命令列
bin/zkcli.sh
2.列出當前所有的topic
ls
/brokers/topics
3.刪除指定的topics
rmr /brokers/topics/
4.停止zookeeper和kafka
5.刪除kafka儲存目錄(server.properties檔案log.dirs配置,預設為"/data/kafka-logs")相關topic的資料目錄。
6.重新啟動zookeeper 和kafka
Linux下搭建kafka環境
apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 啟動zk有兩種方式,第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties ...
Linux下搭建kafka環境
apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 3.啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式,第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh confi...
Linux下kafka環境搭建
一 安裝jdk 首先檢查是否安裝了jdk,如果沒安裝則先安裝jdk kafka 2.10 0.10.0.1.tgz 三 解壓與配置 1.將壓縮包放到安裝目錄下解壓 tar zxvf kafka 2.10 0.10.0.1.tgz 2.資料夾重新命名 mv kafka 2.10 0.10.0.1 ka...