通过百度网盘分享的文件:kafka-eagle-bin-2.0.8.tar.gz
链接:https://pan.baidu.com/s/1H3YONkL97uXbLTPMZHrfdg?pwd=sltu 
提取码:sltu

一、界面展示

二、软件配置

1、关闭kafka集群
kf.sh stop
2、将该软件上传到/opt/modules下
cd /opt/installs

3、解压 由于解压后还是个压缩包,因此先在原地进行解压
tar -zxvf kafka-eagle-bin-2.0.8.tar.gz
4、再次解压,重命名,配置环境变量
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 /etc/profile 

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

source /etc/profile

修改配置文件

/opt/installs/efak/conf/system-config.properties

vi system-config.properties

修改如下:

# offset 保存在 kafka 
cluster1.efak.offset.storage=kafka

efak.zk.cluster.alias=cluster1,cluster2
# 这下面的值需要和kafka配置文件(server.properties)中的 zookeeper.connect的值相照应
cluster1.zk.list=bigdata01:2181,bigdata02:2181,bigdata03:2181/kafka
cluster2.zk.list=bigdata01:2181,bigdata02:2181,bigdata03:2181/kafka


# 记得将sqlite的数据库连接注释掉
# 修改数据库连接:&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

在linux本地的mysql中创建一个数据库(ke)

 三、修改kafka的配置文件

修改/opt/installs/kafka3/bin/kafka-server-start.sh 命令

将 

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then 
 export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" 
fi

修改为下面的

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
 export KAFKA_HEAP_OPTS="-server -Xms2G -Xmx2G -XX:PermSize=128m -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=5 -XX:InitiatingHeapOccupancyPercent=70"
 export JMX_PORT="9999"
 #export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi

将该文件同步给集群中的所有服务器

四、启动

1、启动zk集群

zk.sh start

2、启动kafka集群

kf.sh start

3、启动Eagle

ke.sh start

 访问上面的网站:http://192.168.226.128:8048即可

账号:admin         密码:123456

 三个必须都是Online ,会有点慢,若只有一个,看是不是有broker死了,重启该broker即可

Logo

永洪科技,致力于打造全球领先的数据技术厂商,具备从数据应用方案咨询、BI、AIGC智能分析、数字孪生、数据资产、数据治理、数据实施的端到端大数据价值服务能力。

更多推荐