1.kafka啟動(dòng): ./kafka-server-start.sh ../config/server.properties &

2.創(chuàng)建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某個(gè)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.控制臺(tái)向kafka生產(chǎn)數(shù)據(jù): ./kafka-console-producer.sh --broker-list master:9092 --topic jason_20180519

7.控制臺(tái)消費(fèi)kafka的數(shù)據(jù): ./kafka-console-consumer.sh --zookeeper storm1:2181 --topic jason_20180519 --from-beginning

8.查看topic下某分區(qū)偏移量的最小值: ./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，慎用，只會(huì)刪除zookeeper中的元數(shù)據(jù)，消息文件須手動(dòng)刪除: ./kafka-run-class.sh kafka.admin.DeleteTopicCommand --zookeeper master:2181 --topic yq20171220

11.徹底刪除topic: rmr /brokers/topics/【topic name】即可