flume高并发优化——（5）KafkaOffsetMonitor

本片博客是介绍一款kafka监控的软件，以配合查看flume的kafka channel性能，其实这是个非常简单的项目，我们只需要下载好jar包，就可以使用了
1，下载jar包
http://pan.baidu.com/s/1eSPlzpw

2，启动

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--zk 192.168.2.16:2181 \
--port 8089 \
--refresh 10.seconds \
--retain 30.days

3，查看
输入网址，我的是http://192.168.10.84:8089
效果：



3，参数说明
Topic：创建Topic名称
Partition：分区编号
Offset：表示该Parition已经消费了多少Message
LogSize：表示该Partition生产了多少Message
Lag：表示有多少条Message未被消费
Owner：表示消费者
Created：表示该Partition创建时间
Last Seen：表示消费状态刷新最新时间

总结：
通过观察我们发现，现在虽然kafka的压力不大，但是基本上性能瓶颈的压力都在kafka和es上了，这样我们就能安心吃晚餐了，不会被半夜叫醒调bug了！由此可见，简化架构是一个多么明智的决定啊！希望这几篇博客能帮到你，也不被半夜叫醒！