• 1.启动MySQL数据库
[root@elk93 ~]# cat /etc/my.cnf 
[mysqld]
basedir=/usr/local/mysql8.4
datadir=/var/lib/mysql
socket=/tmp/mysql8.4.sock
port=3306
mysql_native_password=on

[client]
socket=/tmp/mysql8.4.sock
[root@elk93 ~]# 
[root@elk93 ~]# /etc/init.d/mysql.server start
[root@elk93 ~]# ss -ntl | grep 3306
LISTEN 0      151                     *:3306             *:*          
LISTEN 0      70                      *:33060            *:*          
[root@elk93 ~]# 
[root@elk93 ~]# mysql
Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 8
Server version: 8.4.4 MySQL Community Server - GPL

Copyright (c) 2000, 2025, Oracle and/or its affiliates.

Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql>
mysql> CREATE DATABASE kafka;
Query OK, 1 row affected (0.01 sec)

mysql> 
mysql> CREATE USER IF NOT EXISTS kafka IDENTIFIED WITH mysql_native_password BY '123456';
Query OK, 0 rows affected (0.02 sec)

mysql> 
mysql> GRANT ALL ON kafa.* TO 'kafa'@'%';
Query OK, 0 rows affected (0.01 sec)

mysql> 
mysql> SHOW GRANTS FOR kafka;
+--------------------------------------------------------------+
| Grants for kafka@%                                         |
+--------------------------------------------------------------+
| GRANT USAGE ON *.* TO `kafka`@`%`                          |
| GRANT ALL PRIVILEGES ON `oldboyedu_kafka`.* TO `kafka`@`%` |
+--------------------------------------------------------------+
2 rows in set (0.00 sec)

mysql>
  • 2.下载efak-web软件包
[root@elk92 ~]# wget https://github.com/smartloli/kafka-eagle-bin/blob/master/efak-web-3.0.2-bin.tar.gz
  • 3.解压软件包
[root@elk92 ~]# tar xf efak-web-3.0.2-bin.tar.gz  -C /usr/local/
[root@elk92 ~]#
  • 4.修改配置文件
[root@elk92 ~]# egrep -v "^#|^$" /usr/local/efak-web-3.0.2/conf/system-config.properties 
efak.zk.cluster.alias=efak-web
efak-web.zk.list=10.0.0.91:2181,10.0.0.92:2181,10.0.0.93:2181/kafka-3.9.0
efak-web.zk.acl.enable=false
efak-web.efak.broker.size=20
kafka.zk.limit.size=16
efak.webui.port=8048
efak.distributed.enable=false
efak-web.efak.jmx.acl=false
efak-web.efak.offset.storage=kafka
efak-web.efak.jmx.uri=service:jmx:rmi:///jndi/rmi://%s/jmxrmi
efak.metrics.charts=true
efak.metrics.retain=15
efak.sql.topic.records.max=5000
efak.sql.topic.preview.records.max=10
efak.topic.token=efak
efak-web.efak.sasl.enable=false
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://10.0.0.93:3306/oldboyedu_kafka?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=kafka
efak.password=123456
[root@elk92 ~]#
  • 5.修改启动的脚本
[root@elk92 ~]# vim /usr/local/efak-web-3.0.2/bin/ke.sh 
...
export KE_JAVA_OPTS="-server -Xmx256m -Xms256m -XX:MaxGCPauseMillis=20 -XX:+UseG1GC -XX:MetaspaceSize=128m -XX:InitiatingH    eapOccupancyPercent=35 -XX:G1HeapRegionSize=16M -XX:MinMetaspaceFreeRatio=50 -XX:MaxMetaspaceFreeRatio=80"
  • 6.添加环境变量
[root@elk92 ~]# cat /etc/profile.d/kafka.sh 
#!/bin/bash

export KE_HOME=/usr/local/efak-web-3.0.2
export KAFKA_HOME=/usr/local/kafka_2.13-3.9.0
export PATH=$PATH:$KAFKA_HOME/bin:$KE_HOME/bin
[root@elk92 ~]# 
[root@elk92 ~]# source /etc/profile.d/kafka.sh 
[root@elk92 ~]#
  • 7.启动efak程序
...
Welcome to
    ______    ______    ___     __ __
   / ____/   / ____/   /   |   / //_/
  / __/     / /_      / /| |  / ,<   
 / /___    / __/     / ___ | / /| |  
/_____/   /_/       /_/  |_|/_/ |_|  
( Eagle For Apache Kafka® )

Version v3.0.2 -- Copyright 2016-2022
*******************************************************************
* EFAK Service has started success.
* Welcome, Now you can visit 'http://10.0.0.92:8048'
* Account:admin ,Password:123456
...
[root@elk92 ~]# ss -ntl | grep 8048
LISTEN 0      500                     *:8048             *:*          
[root@elk92 ~]#
  • 8.访问efak的WebUI【使用上一步的用户名和密码登录即可】

http://10.0.0.92:8048/tv

efak的搭建需要数据库服务的支持，请自行搭建数据库服务。

Categories: