kafka是什么我就不介绍了,不少人在使用kafka的时候可能不清楚如何监控kafka的一些数据,好比每秒处理了多少消息啊之类的,和一些性能数据,kafka的文档中关于监控讲的实在有些不明确,根本也不说如何监控。让咱们这些非专业JAVA开发人员情何以堪啊。。java
这里主要给你们详细介绍一下如何监控kafka工具
首先从原理上介绍下,kafka的数据统计是通说一个叫metrics的工具进行收集的,metrics是一个java类库,能让你在生成环境下监控你的代码,好比你用java作个网站,他能够帮你统计每秒处理了多少请求之类的数据,在kafka中大量使用了metrics作各类性能统计metrics的官网是http://metrics.codahale.com/,但愿使用metrics的同窗能够去看看,里面有详细文档。固然今天说的监控kafka其实并不须要了解metrics太多。metrics以JMX的形式提供了对外查看数据的接口,所以咱们首先要在kafka启动的时候指定jmx的端口,而后经过现成的可视化工具(visualvm)连过去查看就能够了。性能
一、kafka启动的时候指定jmx的端口 切到kafka的bin目录下,执行下面命令测试
JMX_PORT=9999 ./kafka-server-start.sh ../config/server.properties &
这样就启动kafka了 比平时多了个JMX_PORT=9999而已。网站
二、下载visualvm,官网是 http://visualvm.java.net/ visualvm是一款很好的java诊断,测试工具,开源,还有中文版。 下好后须要安装 MBeans插件,在visualvm里点 工具>>插件 在里面找就能够安装了。.net
三、而后就能够链接了,图形化界面,这里就不详细介绍了 插件
tips:这里提示下,有些同窗可能出死活现连不上的状况,这时候除了考虑防火墙等因素外,注意可能与主机名有关关,kafka貌似会用到主机名,若是主机名是localhost之类的不妨改为IP地址试试.code