1. 程式人生 > >kafka 常用命令

kafka 常用命令

本人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