kafka自帶了很多工具類，在原始碼kafka.tools裡可以看到：

這些類該如何使用呢，kafka的設計者早就為我們考慮到了，在${KAFKA_HOME}/bin下，有很多的指令碼，其中有一個kafka-run-class.sh，通過這個指令碼，可以呼叫其中的tools的部分功能，如呼叫kafka.tools裡的ConsumerOffsetChecker.scala

檢視consumer組內消費的offset：
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper **:2181 --group ** --topic **

其中的group可去zookeeper中檢視：
[[email protected] zookeeper-3.4.5-cdh5.5.2]$ bin/zkCli.sh
[zk: localhost:2181(CONNECTED) 2] ls /consumers
[console-consumer-74653, WordcountConsumerGroup]
（console-consumer-74653這個組當我在另一個視窗啟動消費者[[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-console-consumer.sh --zookeeper h71:2181,h72:2181,h73:2181 --topic test --from-beginning時才會有，關閉消費者程序該組會自動消失）

我們在使用kafka消費資訊的過程中，不同group的consumer是可以消費相同的資訊的，group是在建立consumer時指定的，如果group不存在，會自動建立。其實簡單點說就是每個group都會在zk中註冊，區別就是註冊過還是沒註冊過。每個group內的consumer只能消費在group註冊過之後生產的資訊。

執行結果如下：列出了所有消費者組的所有資訊，包括Group(消費者組)、Topic、Pid(分割槽id)、Offset(當前已消費的條數)、LogSize(總條數)、Lag(未消費的條數)、Owner

[[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 192.168.8.71:2181,192.168.8.72:2181,192.168.8.73:2181 --group WordcountConsumerGroup --topic test
或者：
[
 
[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper=192.168.8.71:2181,192.168.8.72:2181,192.168.8.73:2181 --group=WordcountConsumerGroup --topic=test
再或者：
[[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper=h71:2181 --group=WordcountConsumerGroup
Group           Topic                          Pid Offset          logSize         Lag             Owner
test-consumer-group test                           0   4               40              36              none
test-consumer-group test                           1   14              57              43              none

[[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 192.168.8.71:2181,192.168.8.72:2181,192.168.8.73:2181 --group=WordcountConsumerGroup
Group           Topic                          Pid Offset          logSize         Lag             Owner
WordcountConsumerGroup test                           0   9               40              31              none
WordcountConsumerGroup test                           1   21              57              36              none
[[email protected] kafka_2.10-0.8.2.0]$ bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 192.168.8.71:2181,192.168.8.72:2181,192.168.8.73:2181 --group=console-consumer-42639
Group           Topic                          Pid Offset          logSize         Lag             Owner
console-consumer-42639 test                           0   40              40              0               console-consumer-42639_h71-1498000434797-f1c703cf-0
console-consumer-42639 test                           1   57              57              0               console-consumer-42639_h71-1498000434797-f1c703cf-0

細看kafka-run-class.sh指令碼，它是呼叫了ConsumerOffsetChecker的main方法，所以，我們也可以通過java程式碼來訪問scala的ConsumerOffsetChecker類，程式碼如下：

import kafka.tools.ConsumerOffsetChecker;   
public class hui 
{
    public static void main(String[] args)  
    {
    	//適用於kafka0.8.2.0
        String[] arr = new String[]{"--zookeeper=h71:2181,h72:2181,h73:2181","--group=test-consumer-group"};
        //適用於kafka0.8.1
//    	String[] arr = new String[]{"--zkconnect=h71:2181,h72:2181,h73:2181","--group=test-consumer-group"};
        ConsumerOffsetChecker.main(arr); 
    }
}

跟通過kafa-run-class.sh執行的結果是一樣的

注意：

在http://jxauwxj.iteye.com/blog/2233925部落格中所使用的kafka版本是kafka0.8.1，我一開始按其中的方法在Java程式碼中寫入String[] arr = new String[]{"--zookeeper=h71:2181,h72:2181,h73:2181","--group=test-consumer-group"};總是報錯：

後來才發現，我用的是kafka0.8.2.0版本，並且這兩個版本這塊有差異，我查看了原始碼kafka-0.8.2.0-src.tar\kafka-0.8.2.0-src\core\src\main\scala\kafka\tools\ConsumerOffsetChecker.scala和kafka-0.8.1-src.tar\kafka-0.8.1-src\core\src\main\scala\kafka\tools\ConsumerOffsetChecker.scala

kafka-0.8.2.0：

kafka-0.8.1：

尼瑪，這不是坑爹嗎。。。。。。

並且：在kafka0.8.2.0版本下在Java程式碼中不能寫入"--zookeeper h71:2181,h72:2181,h73:2181","--group test-consumer-group"（在命令列模式下就可以），還必須得有等於號"--zookeeper=h71:2181,h72:2181,h73:2181","--group=test-consumer-group"，不加會報錯：