kafka 常用命令
阿新 • • 發佈:2019-02-02
本人kafka 版本:kafka_2.11-0.10.1.0
1.檢視topic 列表:
./kafka-topics.sh --zookeeper localhost:2181 --list
//以下以 test 為topic 名稱為例
2.建立topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
3.檢視topic明細:
./kafka-topics.sh --describe --zookeeper 192.168.0. 9:2181 --topic test
4.修改topic引數:
./kafka-topics.sh --zookeeper 192.168.0.9:2181 --partition 4 --topic test --alter
5.刪除topic:
bin/kafka-topics.sh --zookeeper 192.168.0.9:2181 --delete --topic test
6.永久刪除topic:
刪除kafka儲存目錄(server.properties檔案log.dirs配置,預設為"/tmp/kafka-logs")相關topic目錄
刪除zookeeper "/brokers/topics/" 目錄下相關topic節點
cd /usr/lib/zookeeper,或 cd <zookeeper安裝目錄>
bin/zkCli.sh -server 127.0.0.1
ls /brokers/topics/test
rmr /brokers/topics/test
rmr /admin/delete_topics/test