Kafka组件研究<五>---- Kafka监控－KafkaOffsetMonitor

5.1 概述

  前面给大家介绍了Kafka的背景以及一些应用场景，并附带上演示了Kafka的简单示例。然后，在开发的过程当中，我们会发现一些问题，那就是消息的监控情况。虽然，在启动Kafka的相关服务后，我们生产消息和消费消息会在终端控制台显示这些记录信息，但是，这样始终不够友好，而且，在实际开发中，我们不会有权限去一直观看终端控制台，那么今天就为大家来介绍Kafka的一个监控系统——KafkaOffsetMonitor。下面是今天所分享的目录内容：

KafkaOffsetMonitor简述
KafkaOffsetMonitor安装部署
KafkaOffsetMonitor运行预览

下面开始今天的内容分享。

5.2 KafkaOffsetMonitor简述

    KafkaOffsetMonitor是有由Kafka开源社区提供的一款Web管理界面，这个应用程序用来实时监控Kafka服务的Consumer以及它们所在的Partition中的Offset，你可以通过浏览当前的消费者组，并且每个Topic的所有Partition的消费情况都可以观看的一清二楚。它让我们很直观的知道，每个Partition的Message是否消费掉，有木有阻塞等等。
    这个Web管理平台保留的Partition、Offset和它的Consumer的相关历史数据，我们可以通过浏览Web管理的相关模块，清楚的知道最近一段时间的消费情况。
该Web管理平台有以下功能：
对Consumer的消费监控，并列出每个Consumer的Offset数据保护消费者组列表信息
每个Topic的所有Partition列表包含：Topic、Pid、Offset、LogSize、Lag以及Owner等等浏览查阅Topic的历史消费信息
这些功能对于我们开发来说，已经绰绰有余了。

5.3 KafkaOffsetMonitor安装部署

   KafkaOffsetMonitor的安装部署较为简单，所有的资源都打包到一个JAR文件中了，因此，直接运行即可，省去了我们去配置。这里我们可以新建一个目录单独用于Kafka的监控目录，我这里新建一个kafka_monitor文件目录，然后我们在准备启动脚本，脚本内容如下所示：

5.4 启动

[root@master2 kafka]# java -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk master2:2181,slave1:2181,slave2:2181 --port 8089 --refresh 10.seconds --retain 1.days

5.5 KafkaOffsetMonitor运行预览