查看CDH版本zookeeper存储的kafka offset值
    启动kafka客户端
    ./opt/cloudera/parcels/CDH/bin/zookeeper-client
    // 查看消费者组为df_app_10,topic为reservation 有几个分区
    ls /consumers/df_app_10/offsets/reservation
小记--------kafka offset维护小记--------kafka offset维护
 
    // 查看消费者组为df_app_10,topic为reservation , partition为0
   get /consumers/df_app_10/offsets/reservation/0
小记--------kafka offset维护小记--------kafka offset维护
 
查看kafka存储的offset值
//命令
    ./kafka-consumer-offset-checker --topic reservation --group df_app_10 --zookeeper df4:2181
// 结果展示
小记--------kafka offset维护小记--------kafka offset维护
 
 
 

相关文章:

  • 2021-08-24
  • 2021-08-26
  • 2021-11-05
  • 2021-12-04
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-11-13
  • 2021-09-01
相关资源
相似解决方案