Kafka可视化

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

安装JDK

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

• 下载JDK 8，下载地址：https://mirrors.tuna.tsinghua.edu.cn/AdoptOpenJDK/

• 下载完成后将JDK解压到指定目录；

cd /mydata/java tar -zxvf OpenJDK8U-jdk_x64_linux_xxx.tar.gzmv OpenJDK8U-jdk_x64_linux_xxx.tar.gz jdk1.8复制代码

• 在/etc/profile文件中添加环境变量JAVA_HOME。

vi /etc/profile# 在profile文件中添加export JAVA_HOME=/mydata/java/jdk1.8export PATH=$PATH:$JAVA_HOME/bin# 使修改后的profile文件生效. /etc/profile复制代码

安装kafka-eagle

• 下载kafka-eagle的安装包，下载地址：https://github.com/smartloli/kafka-eagle-bin/releases

• 下载完成后将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.5export 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复制代码

• 启动成功可以直接访问，输入账号密码admin:123456，访问地址：http://192.168.5.78:8048/

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