kafka常用命令整理

##kafka常用命令

在launcher上，cd /usr/local/kafka_2.11-0.9.0.0/bin
檢視topic的list
./kafka-topics.sh --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181 --list
檢視具體topic的資訊
./kafka-topics.sh --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181 --describe --topic report-ad
檢視具體topic當前消費的實時流
./kafka-console-consumer.sh --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181 --topic report-ad
建立新的topic
./kafka-topics.sh --create --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181 --replication-factor 2 --partitions 18 --topic impression-reformat-part
修改topic
./kafka-topics.sh --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181 --alter --topic extend-event-reformat --replica 2 --partitions 18
往指定topic中灌入資料
cat impression_reformat.list|./kafka-console-producer.sh --broker-list 192.168.1.60:9092,192.168.1.61:9092,192.168.1.62:9092 --topic article-gmp
檢視指定group的消費情況
./kafka-run-class.sh kafka.tools.consumeroffsetchecker --group reformat-click --zookeeper 192.168.1.60:2181,192.168.1.61:2181,192.168.1.62:2181
指定group消費資料
./kafka-console-consumer.sh --consumer.config

kafka安裝整理，附帶常用命令

配置環境變數 export kafka home opt kafka export path path kafka home bin 啟動kafka 普通啟動和後台啟動 kafka server start.sh config server.properties kafka server start...

kafka常用命令

kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...

kafka常用命令

啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...