栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

kafka参数配置详解(kafka配置详解)

kafka参数配置详解(kafka配置详解)

KafkaWeb管理界面EFAK安装(简单配置)

1.安装环境准备2.EFAK安装

1.安装环境准备

1.Linux环境
CentOS7.52.JDK环境
JDK1.83.EFAK软件
kafka-eagle-bin-2.1.0.tar.gz4.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

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/772300.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号