作者：彬
链接：http://www.java78.com/article/70.html
声明：请尊重原作者的劳动，如需转载请注明出处

查看topic信息    

bin/kafka-topics.sh --zookeeper zookeeper:2181 --list
                
TEST1
TEST2
__consumer_offsets

查看消费组

0.8版本及以下的的kafka 使用如下命令查看有那些消费者group
bin/kafka-consumer-groups.sh  --zookeeper zookeeper:2181 --list
0.9版本及以上的kafka建议使用如下命令查看有那些消费者group，当然也可使用上一条命令消费
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
test1
test2  

查看某个消费者消费情况

0.8版本及以下的的kafka 使用如下命令查看名为testgroup 的消费组的消费情况
bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181 --group testgroup --describe
0.9版本及以上的的kafka 使用如下命令查看名为testgroup 的消费组的消费情况
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group portal --describe

修改kafka消费组的位偏移量

将消费组offset设置到最后30分钟                
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test2--reset-offsets --all-topics --by-duration PT0H30M0S
 将消费组offset设置到最新
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test1 --reset-offsets --all-topics --to-latest --execute