Kafka可视化kafka-eagle的安装使用

一.为什么要安装Kafka-eagle

在生产过程中，想创建topic、查看所有topic、想查看某个topic 想查看分区等，都需要写命令，而可视化页面可以把这些操作变成点点点。并且Kafka-Eagle 框架可以监控 Kafka 集群的整体运行情况，在生产环境中经常使用。

Kafka-Eagle 的安装依赖于 MySQL，MySQL 主要用来存储可视化展示的数据。因此你的虚拟机要有mysql才能继续。

二.安装

kafka和kafka-eagle的安装包：
在虚拟机使用的Kafka-2.12-3.0.0资源-CSDN文库
kafka-eagle-bin-2.0.8.tar，虚拟机使用的Kafka的可视化页面资源-CSDN文库

将压缩包放入虚拟机后解压：

tar -zxvf kafka-eagle-bin-2.0.8.tar.gz
cd kafka-eagle-bin-2.0.8
tar -zxvf efak-web-2.0.8-bin.tar.gz -C /opt/installs/ 

然后修改名称方便使用：

mv efak-web-2.0.8/ efak 

修改其配置文件：

vi system-config.properties
修改如下：
# offset 保存在 kafka 
cluster1.efak.offset.storage=kafka

efak.zk.cluster.alias=cluster1,cluster2
cluster1.zk.list=bigdata01:2181,bigdata02:2181,bigdata03:2181/kafka
cluster2.zk.list=bigdata01:2181,bigdata02:2181,bigdata03:2181/kafka

# 修改数据库连接：&serverTimezone=GMT  时区一定要写，否则报405错误！
# 127.0.0.1 = localhost   hosts文件中定义的
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT
efak.username=root
efak.password=123456

添加环境变量：

# kafkaEFAK
export KE_HOME=/opt/installs/efak
export PATH=$PATH:$KE_HOME/bin

添加完成后记得刷新：source /etc/profile

查看一下mysql：systemctl status mysqld看看mysql是否正常运行

然后创建一个叫ke的数据库，为什么是ke？

如上图所示这是在配置文件里决定的

三.启动

启动zookeeper，zh.sh start
启动kafka，kf.sh start

启动efak：ke.sh start

这时可以看到zk数据库多出了18张表：

如果无法启动的话：

cluster1.zk.list=hadoop11:2181,hadoop12:2181,hadoop13:2181/kafka
cluster2.zk.list=hadoop11:2181,hadoop12:2181,hadoop13:2181/kafka

检查一下自己的配置文件修改的是否是自己的ip

正确启动如下：

最后出现欢迎界面：

按给出的链接访问，账户密码填写后：

可以查看集群状态：

还有节点状态等，以及一个可视化大屏：

操作都可以在这些页面点点点实现，也是比较的方便。