当前位置: 代码迷 >> 综合 >> KafkaWeb管理EFAK(原名kafka-eagle)安装(简单配置)
  详细解决方案

KafkaWeb管理EFAK(原名kafka-eagle)安装(简单配置)

热度:68   发布时间:2023-12-09 04:33:51.0

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