版本flink1.11.0 请问下各位大佬MetricQueryService这个类中定义的四种类型metric的值是怎么更新的？比如kafka的current-offset是Gauge类型，MetricQueryService中gauges这个map对应的current-offset的值怎么更新的呢？只看到addMetric这个方法是put值的，但是通过本地调试和代码走读，这个方法只是一开始注册用的，运行过程如何更新metric的？ -- Sent from: http://apache-flink.147419.n8.nabble.com/