【原创】Kakfa metrics包源代码分析

这个包主要是与Kafka度量相关的。

一、KafkaTimer.scala

对代码块的运行进行计时。仅提供一个方法: timer——在运行传入函数f的同时为期计时

二、KafkaMetricsConfig.scala

指定reporter类，以逗号分隔的reporter类，比如kafka.metrics.KafkaCSVMetricsReporter，这些类必须要在claasspath中指定。另外指定了度量的轮询间隔，默认是10秒。

三、KafkaMetricsReporter.scala

KafkaMetricsReporterMBean是基本trait。客户如果要自己定制reporter的话除了要实现KafkaMetricsReporter之外还要实现这个MBean以满足标准的MBean规范。该trait定义了3个抽象方法：

1. startReporter: 调用yammer的CsvReporter的start方法开启reporter

2. stopReporter: 调用yammer的CsvReporter的shutdown方法关闭reporter

3. getMBeanName: 获取MBean的名称，格式为：kafka:type=kafka.metrics.KafkaCSVMetricsReporter

该scala文件还提供了第二个trait: KafkaMetricsReporter，该trait只有一个方法init，在KafkaCSVMetricsReporter.scala中实现了该init方法

最后，该scala还有一个object: KafkaMetricsReporter。该object维护了一个AtomicBoolean的ReporterStarted变量，标识该reporter是否已经启动，并在启动reporter的过程中充当锁的作用。该object唯一的方法startReporters就是启动MetricConfig中定义的所有reporter——具体方法是调用Utils.createObject方法通过反射机制创建所有reporter，并初始化每个reporter，最后将reporter注册到MBean中。

四、KafkaCSVMetricsReporter.scala

该scala可以说Kafka默认提供的一个具体reporter。一共提供了两个MBean：KafkaCSVMetricsReporterMBean和KafkaCSVMetricsReporter。我们先说第一个：KafkaCSVMetricsReporterMBean。该trait是一个私有trait，就是简单地继承了KafkaMetricsReporterMBean。

而第二个trait继承了KafkaMetricsMBean和KafkaCSVMetricsReporterMBean，因而实现了前两个trait的4个方法，分别是init, getMBeanName, startReporter和stopReporter。值得一提的是，在init方法中它会创建一个默认为kafka_metrics的子目录，然后判断是否kafka.csv.metrics.reporter.enabled设定为true，如果true的话调用startReporter方法开启report，否则就直接结束。

五、KafkaMetricsGroup.scala

该scala定义了一个trait和一个object。就KafkaMetricsGroup trait而言，顾名思义，这应该是个metric组，定义了很多方法，主要的方法就是newGauge、newMeter、newHistogram和newTimer调用yammer框架的api创建不同的度量元对象。

而该scala的object： KafkaMetricsGroup分别为consumer、server、producer定义了各自的metric列表。当然还提供了remove方法删除给定clientId的metric

转载于:https://www.cnblogs.com/huxi2b/p/4401461.html

【原创】Kakfa metrics包源代码分析相关推荐

【原创】Kakfa api包源代码分析
既然包名是api,说明里面肯定都是一些常用的Kafka API了. 一.ApiUtils.scala 顾名思义,就是一些常见的api辅助类,定义的方法包括: 1. readShortString: 从 ...
【原创】kafka client源代码分析
该包下只有一个文件:ClientUtils.scala.它是一个object,里面封装了各种client(包括producer,consumer或admin)可能会用到的方法: 1. fetchTop ...
spark(1.1) mllib 源代码分析
在spark mllib 1.1加入版本stat包,其中包括一些统计数据有关的功能.本文分析中卡方检验和实施的主要原则: 一个.根本在stat包实现Pierxunka方检验,它包括以下类别 (1)适 ...
Spark SQL Catalyst源代码分析Optimizer
/** Spark SQL源代码分析系列*/ 前几篇文章介绍了Spark SQL的Catalyst的核心运行流程.SqlParser,和Analyzer 以及核心类库TreeNode,本文将具体解说S ...
Spark SQL之External DataSource外部数据源（二）源代码分析
上周Spark1.2刚公布,周末在家没事,把这个特性给了解一下,顺便分析下源代码,看一看这个特性是怎样设计及实现的. /** Spark SQL源代码分析系列文章*/ (Ps: External Da ...
Hadoop源代码分析
http://wenku.baidu.com/link?url=R-QoZXhc918qoO0BX6eXI9_uPU75whF62vFFUBIR-7c5XAYUVxDRX5Rs6QZR9hrBnUdM ...
Hadoop源代码分析(完整图文版) part 1
在网上看到了很多此文章的装载,但是都是纯文字,这篇文章在没有图片的情况下阅读起来意义不大了.花了点时间上传了100多张图片,希望对大家学习hadoop有帮助. Hadoop源代码分析(一) 关键字: ...
Hadoop源代码分析(完整版)
Hadoop源代码分析(一) 关键字: 分布式云计算 Google的核心竞争技术是它的计算平台.Google的大牛们用了下面5篇文章,介绍了它们的计算设施. GoogleCluster:http:/ ...
Android系统默认Home应用程序（Launcher）的启动过程源代码分析
在前面一篇文章中,我们分析了Android系统在启动时安装应用程序的过程,这些应用程序安装好之后,还需要有一个Home应用程序来负责把它们在桌面上展示出来,在Android系统中,这个默认的Home应 ...

【原创】Kakfa metrics包源代码分析

【原创】Kakfa metrics包源代码分析相关推荐

最新文章

热门文章