1、前臺程序啟動：  ./kafka-server-start.sh ../config/server.properties &

2、後臺程序啟動：  ./kafka-server-start.sh -daemon ../config/server.properties &

3、停止kafka服務     ./kafka-server-stop.sh     4、命令建立topic    ./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test

5、查詢已建立的topic   ./kafka-topics.sh --list --zookeeper localhost:2181

6、傳送kafka訊息   ./kafka-console-producer.sh  --broker-list localhost:9092 --topic test   ./kafka-console-producer.sh  --broker-list 10.10.10.10:9096 --topic testTopic      接收kafka訊息2017/12/21 15:54:17    ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test    ./kafka-console-consumer.sh --zookeeper 10.10.10.10:2181 --topic testTopic

  7、查詢偏移量 ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper  10.10.10.10:2181 --group commons.sdk.consumer

                                                zk偏移量     總大小     剩餘大小

Group                              Topic        Pid            Offset      logSize     Lag     Owner

commons.sdk.consumer testTopic      0              169          169          0       commons.sdk.consumer_WWX203898-1502938783374-35c2debb-0

8、通過zk查詢偏移量

查詢offset最大值 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.10.10.10:9096 -topic testTopic --time -1

查詢offset最小值 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.10.10.10:9096 -topic testTopic --time -2

查詢zk中kafka的偏移量 1、登陸zk服務 2、get /consumers/commons.sdk.consumer/offsets/testTopic/0