赞
踩
1.进入zookeeper的客户端界面:./zkCli.sh(在zookeeper目录的bin下)
查看目录:ls /consumers
2.kafka的bin目录下执行:
./kafka-consumer-groups.sh --describe --group xiothub_jtm2m_rawdata_210_xgit_m2m_jt_LOCAL --zookeeper localhost:2181
xiothub_jtm2m_rawdata_210_xgit_m2m_jt_LOCAL 是上面从zookeeper中查询出来的consumer
标记解释:
TOPIC | PARTITION | CURRENT-OFFSET | LOG-END-OFFSET | LAG | CONSUMER-ID | HOST | CLIENT-ID |
---|---|---|---|---|---|---|---|
topic名字 | 分区id | 当前已消费的条数 | 总条数 | 未消费的条数 | 消费id | 主机ip | 客户端id |
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。