当Kafka消费者应用程序启动并运行时,我们可以使用kafka-consumer-groups.sh来描述和检索偏移状态 . 但是,如果应用程序关闭,则命令只显示应用程序处于重新 balancer 状态 . 有没有办法只看到特定消费者群体的滞后,即使应用程序没有启动并运行?

GROUP|TOPIC|PARTITION|CURRENT-OFFSET|LOG-END-OFFSET|LAG
hrly_ingest_grp|src_hrly|4|63832846|63832846|0
hrly_ingest_grp|src_hrly|2|38372346|38372346|0
hrly_ingest_grp|src_hrly|0|58642250|58642250|0
hrly_ingest_grp|src_hrly|5|96295762|96295762|0
hrly_ingest_grp|src_hrly|3|50602337|50602337|0
hrly_ingest_grp|src_hrly|1|29288993|29288993|0