Kafka可视化

使用命令行操作Kafka确实有点麻烦，接下来我们试试可视化工具kafka-eagle。

安装JDK

如果你使用的是CentOS的话，默认没有安装完整版的JDK，需要自行安装！

  • 下载完成后将JDK解压到指定目录；
cd /mydata/java
tar -zxvf OpenJDK8U-jdk_x64_linux_xxx.tar.gz
mv OpenJDK8U-jdk_x64_linux_xxx.tar.gz jdk1.8
复制代码
  • 在/etc/profile文件中添加环境变量JAVA_HOME。
vi /etc/profile
# 在profile文件中添加
export JAVA_HOME=/mydata/java/jdk1.8
export PATH=$PATH:$JAVA_HOME/bin
# 使修改后的profile文件生效
. /etc/profile
复制代码

安装kafka-eagle

  • 下载完成后将kafka-eagle解压到指定目录；
cd /mydata/kafka/
tar -zxvf kafka-eagle-web-2.0.5-bin.tar.gz
复制代码
  • 在/etc/profile文件中添加环境变量KE_HOME；
vi /etc/profile
# 在profile文件中添加
export KE_HOME=/mydata/kafka/kafka-eagle-web-2.0.5
export PATH=$PATH:$KE_HOME/bin
# 使修改后的profile文件生效
. /etc/profile
复制代码

  • 安装MySQL并添加数据库ke，kafka-eagle之后会用到它；

  • 修改配置文件$KE_HOME/conf/system-config.properties，主要是修改Zookeeper的配置和数据库配置，注释掉sqlite配置，改为使用MySQL；

######################################
# multi zookeeper & kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=localhost:2181

######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048

######################################
# kafka sqlite jdbc driver address
######################################
# kafka.eagle.driver=org.sqlite.JDBC
# kafka.eagle.url=jdbc:sqlite:/hadoop/kafka-eagle/db/ke.db
# kafka.eagle.username=root
# kafka.eagle.password=www.kafka-eagle.org

######################################
# kafka mysql jdbc driver address
######################################
kafka.eagle.driver=com.mysql.cj.jdbc.Driver
kafka.eagle.url=jdbc:mysql://localhost:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
kafka.eagle.username=root
kafka.eagle.password=root
复制代码
  • 使用如下命令启动kafka-eagle；
$KE_HOME/bin/ke.sh start
复制代码
  • 命令执行完成后会显示如下信息，但并不代表服务已经启动成功，还需要等待一会；

  • 再介绍几个有用的kafka-eagle命令：
# 停止服务
$KE_HOME/bin/ke.sh stop
# 重启服务
$KE_HOME/bin/ke.sh restart
# 查看服务运行状态
$KE_HOME/bin/ke.sh status
# 查看服务状态
$KE_HOME/bin/ke.sh stats
# 动态查看服务输出日志
tail -f $KE_HOME/logs/ke_console.out
复制代码

  • 登录成功后可以访问到Dashboard，界面还是很棒的！