小记--------kafka offset维护

查看CDH版本zookeeper存储的kafka offset值
    启动kafka客户端
    ./opt/cloudera/parcels/CDH/bin/zookeeper-client
    // 查看消费者组为df_app_10,topic为reservation 有几个分区
    ls /consumers/df_app_10/offsets/reservation
 
    // 查看消费者组为df_app_10,topic为reservation , partition为0
   get /consumers/df_app_10/offsets/reservation/0
 
查看kafka存储的offset值
//命令
    ./kafka-consumer-offset-checker --topic reservation --group df_app_10 --zookeeper df4:2181
// 结果展示
 
 
 
原文地址:https://www.cnblogs.com/yzqyxq/p/12846929.html