1.檢視kafka所在目錄,檢視znode目錄

ps -ef|grep kafka
cd /app/kafka/kafka_2.11-1.0.0/bin/
cd ../config
vi server.properties
檢視kafka 在zookeeper 上面的znode節點位置，這裡注意可能zk後面是目錄結構

2.建立topic：1分割槽 1備份

./kafka-topics.sh --create --zookeeper xx.xx.xx.xx:2181/kafka --replication-factor 1 --partitions 1 --topic IN_OUT_TEST

3.命令列從頭消費topic

過時：
./kafka-console-consumer.sh --zookeeper xx.xx.xx.xx:2181/kafka --from-beginning --topic IN_OUT_TEST
現在：
./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.xx:9092 --from-beginning --topic IN_OUT_TEST

4.展示所有topic列表

./kafka-topics.sh --list --zookeeper xx.xx.xx.xx:2181/kafka

5.檢視topic組下面，topic的消費情況

./kafka-consumer-groups.sh --describe --bootstrap-server xx.xx.xx.xx:9092 --group test_group
| TOPIC     |  PARTITION | CURRENT-OFFSET | LOG-END-OFFSET |     LAG     | CONSUMER-ID |  HOST  | CLIENT-ID |
| ----------| ---------- | -------------- | -------------- | ----------- | ----------- | ------ | --------- | 
  topic名字      分割槽id     當前已消費的條數       總條數         未消費的條數       消費id      主機ip     客戶端id 
 

6.檢視topic：偏移量、主節點、副本

./kafka-topics.sh --describe --zookeeper xx.xx.xx.xx:2181/kafka --topic IN_OUT_TEST

7.刪除沒用的topic

./kafka-topics.sh --delete --zookeeper xx.xx.xx.xx:2181/kafka --topic IN_OUT_TEST

8.檢視所有使用者組

./kafka-consumer-groups.sh --bootstrap-server xx.xx.xx.xx:9092 --list