kafka常用命令（cdh5.10.0+kafka）

參考資料：http://kafka.apache.org/quickstart

進入kafka安裝目錄（CDH安裝路徑為：/opt/cloudera/parcels/KAFKA）：
進入bin目錄：

cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin

創建topic，一個備份，6個分區

kafka-topics --create --zookeeper personas1:2181 --replication-factor 1 --partitions 6 --topic TP_LABEL

查看所有topic

kafka-topics --list --zookeeper personas1:2181

增加分區

kafka-topics --zookeeper personas1:2181 --alter --topic TP_LABEL --partitions 8

消費者

 

kafka-console-consumer --zookeeper personas1:2181,personas2:2181,personas4:2181 --topic TP_LABEL

刪除kafka topic（1、刪除topic，2、刪除zk注冊信息，3、刪除源數據）

 

kafka-topics --delete --zookeeper personas1:2181 --topic TP_LABEL

進入CDH bin目錄

 

 

cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin
zookeeper-client
rmr /brokers/topics/TP_LABEL

刪除源數據，刪除分區源數據（如果只有一個topic，直接把data刪掉）

 

cd /var/local/kafka/data
rm -rf TP_LABEL-*

徹底清除zk中的注冊信息，把kafka停掉，只保留箭頭所指的配置，把其他kafka的信息全部刪除