KafkaWeb管理界面EFAK安装(简单配置)
- 1.安装环境准备
- 2.EFAK安装
1.安装环境准备
- 1.Linux环境
CentOS7.5 - 2.JDK环境
JDK1.8 - 3.EFAK软件
kafka-eagle-bin-2.1.0.tar.gz - 4.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