方便日常使用：
1.kafka啟動: ./kafka-server-start.sh -daemon ../config/server.properties
2.建立topic: ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tes
3.檢視kafka的topic：./kafka-topics.sh --zookeeper master:2181 --list
4.檢視kafka某個topic下partition資訊: ./kafka-topics.sh --describe --zookeeper master:2181 --topic test-topic
5.檢視kafka的指定topic: ./kafka-topics.sh --zookeeper master:2181 --describe --topic yq20171220
6.控制台向kafka生產資料: ./kafka-console-producer.sh --broker-list hadoop001:9092 --topic jason_20180519
7.控制台消費kafka的資料: ./kafka-console-consumer.sh --bootstrap-server hadoop001:9092 --topic jason_20180519 --from-beginning
8.檢視topic下某分割槽偏移量的最小值: ./kafka-run-class.sh kafka.tools.getoffsetshell --topic test-topic --time -1 --broker-list master:9092 --partitions 0
9.增加topic的partition:/kafka-topics.sh --alter --topic jason_20180519 --zookeeper 10.200.10.24:2181,10.200.10.26:2181,10.200.10.29:2181 --partitions 5
10.刪除topic，慎用，只會刪除zookeeper中的元資料，訊息檔案須手動刪除: ./kafka-run-class.sh kafka.admin.deletetopiccommand --zookeeper master:2181 --topic yq20171220
11.徹底刪除topic: rmr /brokers/topics/【topic name】即可
建立topic時，partitions 分割槽數量，會均勻的分布在broker上 ，replication-factor 副本數量，不能超過broker的數量
參考：zookeeper命令：
zookeeper服務命令:
1. 啟動zk服務: sh bin/zkserver.sh start
2. 檢視zk服務狀態: sh bin/zkserver.sh status
3. 停止zk服務: sh bin/zkserver.sh stop
4. 重啟zk服務: sh bin/zkserver.sh restart
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...
Kafka 常用命令
kafka console producer broker list 127.0.0.1 9092 topic mytopic kafka console consumer bootstrap server 127.0.0.1 9092 topic mytopic 建立主題,replication ...