1.安装环境准备2.EFAK安装
1.安装环境准备1.Linux环境
CentOS7.52.JDK环境
JDK1.83.EFAK软件
kafka-eagle-bin-2.1.0.tar.gz4.mysql服务环境(可缺)
mysql8.0
2.EFAK安装
1.软件下载
官网地址:http://download.kafka-eagle.org/
百度网盘链接:https://pan.baidu.com/s/1U7EOpLjhYA81bGb4kiWAGA?pwd=wd29
2.上传解压
上传工具:Xshell6(当然你也可以使用其他连接工具处理)
上传至服务器,例如放置在:/usr/app/kafka/目录下,解压文件:
## 首次解压(剥去外壳) tar -zxvf kafka-eagle-bin-2.1.0.tar.gz ## 进入kafka-eagle-bin-2.1.0目录 cd kafka-eagle-bin-2.1.0 ## 再次解压(这才是真正的解压) tar -zxvf efak-web-2.1.0-bin.tar.gz ## 移动至 /usr/app/kafka/ 目录下 mv efak-web-2.1.0 /usr/app/kafka/
3.配置环境变量路径
a.打开环境变量文件,vim /etc/profile
b.编写KE_HOME配置然后保存,内容如下(保存操作:英文输入下,按 ESC 键,输入 wq 即可)。
## JDK环境变量 JAVA_HOME=/usr/app/java/jdk1.8.0_221 PATH=$PATH:$JAVA_HOME/bin CLASSPATH=.:$JAVA_HOME/lib export JAVA_HOME PATH CLASSPATH ## KE环境变量 export KE_HOME=/usr/app/kafka/efak-web-2.1.0 export PATH=$PATH:$KE_HOME/bin
c.启用环境变量配置,source /etc/profile
4.编辑配置文件
需要注意的是提前备份解压后的配置文件。
## 移动到 efak 安装目录 cd /usr/app/kafka/efak-web-2.1.0/ ## 备份原始配置 cp conf/system-config.properties -a conf/system-config.properties.bak ## 编辑配置文件 vim conf/system-config.properties
文件内容如示。
###################################### # Kafka使用的Zookeeper集群别名,多个集群用逗号分隔,后续针对不同集群配置都需要别名作前缀 efak.zk.cluster.alias=cluster1 # Kafka配置的Zookeeper集群客户端访问地址 cluster1.zk.list=192.168.235.102:2181 ###################################### # zk client thread limit # EFAK跟Zookeeper的最大连接数 ###################################### kafka.zk.limit.size=25 ###################################### # EFAK webui port # efak的Web界面访问端口 ###################################### efak.webui.port=8048 ###################################### # kafka offset storage ###################################### cluster1.efak.offset.storage=kafka ###################################### # kafka jmx uri ###################################### cluster1.efak.jmx.uri=service:jmx:rmi:///jndi/rmi://%s/jmxrmi ###################################### # kafka metrics, 15 days by default ###################################### efak.metrics.charts=true efak.metrics.retain=15 ###################################### # kafka sql topic records max ###################################### efak.sql.topic.records.max=5000 efak.sql.topic.preview.records.max=10 ###################################### # kafka sqlite jdbc driver address -- 自带数据库 ###################################### #efak.driver=org.sqlite.JDBC #efak.url=jdbc:sqlite:/usr/app/kafka/efak-web-2.1.0/db/ke.db #efak.username=root #efak.password=smartloli ###################################### # kafka mysql jdbc driver address -- 外部数据库 ###################################### efak.driver=com.mysql.cj.jdbc.Driver efak.url=jdbc:mysql://192.168.235.110:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull efak.username=root efak.password=Mysql@123
注意:使用EFAK自身的数据时需要开启自带数据库配置,关闭外部数据源配置。
5.调整启动参数,EFAK默认启动内存大小为2G,考虑到服务器情况可以将其调小
## 在 efak 安装目录执行 vim bin/ke.sh ## 将 KE_JAVA_OPTS 最大最小容量调小,例如: export KE_JAVA_OPTS="-server -Xmx512m -Xms512m -XX:MaxGCPauseMillis=20 -XX:+UseG1GC -XX:metaspaceSize=128m -XX:InitiatingHeapOccupancyPercent=35 -XX:G1HeapRegionSize=16M -XX:MinmetaspaceFreeRatio=50 -XX:MaxmetaspaceFreeRatio=80"
6.启动服务
命令行执行:ke.sh start启动(这就是环境变量的作用),启动界面如示(标记了访问账号和密码)。
7.开放防火墙访问端口
## 添加 8048 端口 firewall-cmd --add-port=8048/tcp --permanent ## 重启防火墙 firewall-cmd --reload
8.外部访问验证
输入:ip + 8048端口即可,例如:http://192.168.235.102:8048/。页面如示。
其他命令:
# 重启命令 ke.sh restart # 停止命令 ke.sh stop # 查看状态(是否启动) ke.sh status
以上就是EFAK简单使用安装指南。
官方文档地址:http://www.kafka-eagle.org/articles/docs/installation/linux-macos.html



