当前位置：首页 > article >正文

Kafka-Eagle的配置——kafka可视化界面

article 2024/11/14 12:04:51

通过百度网盘分享的文件：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

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