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

版权声明：本文为ljangle原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/ljangle/p/8952706.html