Kafka快速入门系列(14) | Kafka监控(两种)

  本篇博主带来的是Kafka的两种监控软件。


一. Kafka Monitor

  • 1. 上传jar包KafkaOffsetMonitor-assembly-0.4.6.jar到集群
    1
  • 2.在/opt/module/下创建kafka-offset-console文件夹
[bigdata@hadoop002 module]$ mkdir kafka-offset-console
[bigdata@hadoop002 module]$ cd kafka-offset-console/


  
 
  • 1
  • 2
  • 3
  • 3. 将上传的jar包放入刚创建的目录下
[bigdata@hadoop002 kafka-offset-console]$ cp /opt/software/Kafka/KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar ./

  
 
  • 1
  • 4. 在/opt/module/kafka-offset-console目录下创建启动脚本start.sh,内容如下
[bigdata@hadoop002 kafka-offset-console]$ vim start.sh

#!/bin/bash
java -cp KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--offsetStorage kafka \
--kafkaBrokers hadoop002:9092,hadoop003:9092,hadoop004:9092 \
--kafkaSecurityProtocol PLAINTEXT \
--zk hadoop002:2181,hadoop003:2181,hadoop004:2181 \
--port 8086 \
--refresh 10.seconds \
--retain 2.days \
--dbName offsetapp_kafka &


// 变成和执行性文件
[bigdata@hadoop002 kafka-offset-console]$ chmod +x start.sh

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 5. 在/opt/module/kafka-offset-console目录下创建mobile-logs文件夹
[bigdata@hadoop002 kafka-offset-console]$ mkdir mobile-log

  
 
  • 1
  • 6. 启动KafkaMonitor
[bigdata@hadoop002 kafka-offset-console]$ ./start.sh 

  
 
  • 1

2
如果出现下图就代表成功了

  • 7.登录页面hadoop002:8086端口查看详情
    3

下面可以进行一些简单的操作

  • 先分别进行生产消费

4

  • 然后通过web端进行查看
    5

二. Kafka Manager

  • 1.解压到/opt/module
[bigdata@hadoop002 Kafka]$ unzip kafka-manager-1.3.3.15.zip -d /opt/module/


  
 
  • 1
  • 2
  • 2.修改配置文件conf/application.conf
[bigdata@hadoop002 kafka-manager-1.3.3.15]$ vim conf/application.conf kafka-manager.zkhosts="kafka-manager-zookeeper:2181"
修改为:
kafka-manager.zkhosts="hadoop002:2181,hadoop003:2181,hadoop004:2181"


  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 3. 为脚本添加执行权限
[bigdata@hadoop002 bin]$ chmod +x kafka-manager

  
 
  • 1

6

  • 4. 启动kafka-manager
[bigdata@hadoop002 kafka-manager-1.3.3.15]$ bin/kafka-manager 

// 修改端口号
[bigdata@hadoop002 kafka-manager-1.3.3.15]$ bin/kafka-manager -Dhttp.port=9090

  
 
  • 1
  • 2
  • 3
  • 4
  • 5. 登录hadoop002:9000页面查看详细信息
    7
    出现上图即为成功
    8
  • 6. 手动添加Cluster(除了标记处,其他均为默认即可)
    8
  • 7. 查看
    9

10
剩下的一些具体操作可以自行摸索,或者等到博主有时间会专门出一期教程!

  本次的分享就到这里了,


11

   看 完 就 赞 , 养 成 习 惯 ! ! ! \color{#FF0000}{看完就赞,养成习惯!!!} ^ _ ^ ❤️ ❤️ ❤️
  码字不易,大家的支持就是我坚持下去的动力。点赞后不要忘了关注我哦!

文章来源: buwenbuhuo.blog.csdn.net,作者:不温卜火,版权归原作者所有,如需转载,请联系作者。

原文链接:buwenbuhuo.blog.csdn.net/article/details/105982269

(完)