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的消费情况了