如何知道kafka是否正常生产消费？看看客户端指标采集

1. Metrics收集原理

Metrics类用来管理kafka运行产生的各种埋点数据，内部管理两个关键类：Metric和Sensor.

1.1 Metric

程序运行时会产生各种数据，Metric封装了获取这些数据的细节，提供给外界使用(Facade Pattern)。每一个Metric代表一种类型的数据，一系列Metic组成所有维度的统计数据，通过Measurable方法获取具体的数据。如下图所示：

图1 Metric收集原理

1. 程序运行的过程中不断产生各种数据，这些数据可以是当前的某个状态，比如访问次数总和，也可以是历史记录，比如每分钟的统计次数。这些指标数据可以是内存中的一个变量，也可以保存到数据库中。
2. 需要统计的指标为一个Metric，用来供外界查看。
3. 我们需要建立一个从Metric到数据的映射关系，这就通过Measurable来建立。

比如：

// 数据
int count = 0;
 
// metrics “api”
addMetric(metricName("count", "kafka-metrics-count", "total number of registered metrics"),
          //metrics到数据的映射方式
      new Measurable() {
               @Override