采纳
1、构建kafka监控服务,使用开源三方的监控服务但是里面使用kafka版本0.10.2,调用方法listGroupOffset方式提示(Request GROUP_COORDINATOR failed on brokers List)
(Request GROUP_COORDINATOR failed on brokers List)
2、在命令行模式下使用 kafka-consumer-group命令可以获取消费lag
kafka-consumer-group
lag
3、尝试使用jmx方式获取消费组Lag也没有相应的Mbean