kafka查看队列的消费情况

kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --broker-info --group $group --topic $topic --zookeeper $zk_host:2181

0.9.0以后官方建议使用

kafka-consumer-groups.sh --new-consumer --bootstrap-server $broker:9092 --describe --group $topic