kafka里面的topic消費情況查看

使用storm實時處理kafka中topic的數據，想要查看該topic的消費情況

如何實現：進入zookeeper的客戶端界面：./zkCli.sh-----

查看目錄：

於此回應的代碼層面：-------此處為topic對應的消費組，其存儲路徑實在zookeeper下面

String zkRoot = "/stormkafka"; 
        //相當與消費組
//        String id = "hbase_data2";
        String id = "hbase_data6";
        BrokerHosts brokerHosts = new ZkHosts(zks);
        SpoutConfig spoutConf = new SpoutConfig(brokerHosts, topic, zkRoot, id)；

 接下來查看消費組目錄下的對應情況：

 

可以看到此處是topic的分區目錄

對此就可以查看topic的消費情況了