Stay hungry Stay foolish

Kafka-Web-Console-安装记录

Posted on By blue

目录



一、Kafka-Web-Console介绍

Kafka Web Console is a Java web application for monitoring Apache Kafka. With a modern web browser, you can view from the console

使用Kafka Web Console,可以监控:

  • Brokers列表

  • Kafka 集群中 Topic列表,及对应的Partition、LogSiz e等信息

  • 点击Topic,可以浏览对应的Consumer Groups、Offset、Lag等信息

  • 生产和消费流量图、消息预览…

github地址:https://github.com/claudemamo/kafka-web-console

二、系统及软件环境

jdk1.7

Red Hat Enterprise Linux Server release 6.4


三、开始安装

1、下载代码

git clone https://github.com/claudemamo/kafka-web-console.git

2、安装sbt

去官网下载sbt介质,安装完成后,在.bash_profile中配置PATH路径

PATH=$PATH:$HOME/bin:/usr/kafka-web-console/sbt/bin

3、重载环境变量,进入kafka-web-console安装目录,执行:

sbt package

需要耐心等待一会儿,这个过程中会下载项目所需的依赖包

4、下载完成后,启动项目,并指定端口为8080:

sbt run -Dhttp.port=8080

5、控制输出如下信息,表示启动成功,

[root@slave181 kafka-web-console]# sbt run -Dhttp.port=8080
[info] Loading project definition from /usr/kafka-web-console/kafka-web-console/project
[info] Set current project to kafka-web-console (in build file:/usr/kafka-web-console/kafka-web-console/)

--- (Running the application from SBT, auto-reloading is enabled) ---

[info] play - Listening for HTTP on /0:0:0:0:0:0:0:0:8080

(Server started, use Ctrl+D to stop and go back to the console...)

6、打开浏览器,输入IP:Port进入kafka-web-console,第一次进入,需要做一些初始化动作,直接点击鼠标,下一步操作即可。完成之后,注册Zookeeper,既可对Kafka进行监控。

四、后台运行

根据控制台信息提示,按Ctrl+D可以将进程放在后台运行,尝试多次,程序直接停掉,均没有成功。

编写一个简单的shell脚本:

#!/bin/sh
sbt run -Dhttp.port=8080

然后执行 ` ./start.sh &`

程序依然退出,无法在后台运行。

最终,在网上找了一个解决方法:

 screen -d -m sbt run -Dhttp.port=8080

模拟一个窗口,将程序放在后台运行。

五、 修改默认数据库(可选)

这一步不是必须的,使用默认的H2数据也可以,但H2数据库对Linux支持不够友好,不能方便的查看一些表的状态及数据。

另外,在Kafka Log Size 过大时,使用H2数据库,在界面中,Log Size显示为0,估计是一个Bug

1、修改kafka-web-console/conf/application.conf

 db.default.driver=com.mysql.jdbc.Driver
 db.default.url="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF8&connectTimeout=5000&socketTimeout=10000"
 db.default.user=root
 db.default.password="123456"
  
 #db.default.driver=org.h2.Driver
 #db.default.url="jdbc:h2:file:play"
 #db.default.user=sa
 #db.default.password=""

将默认的数据配置信息注释,新增MySql的数据地址信息

2、进入Mysql,新建程序所需的表,Sql脚本在kafka-web-console/conf/evolutions/default/ 目录中。官方并没有提供MySql版的建表脚本,需要自行修改。以下为已经改好的Mysql版本:

点击下载