- 需要提前开启几个端口号的公网访问权限
- 1.8048 kafka-eagle的登录UI界面默认端口
- 2.8085
- 3.9999 kafka-jmx信息发送端口
- 4.9393
- 5.8065
- 官网：https://www.kafka-eagle.org/
- 上传压缩包 kafka-eagle-bin-3.0.1.tar.gz 到安装有kafka-broker的服务器上
- 上传压缩包 kafka-eagle-bin-3.0.1.tar.gz 到安装有kafka-broker的服务器上
- 本次安装在hadoop103服务器上
- 解压
- tar -zxvf kafka-eagle-bin-3.0.1.tar.gz
- cd kafka-eagle-bin-3.0.1
- tar -zxvf efak-web-3.0.1-bin.tar.gz
- mv efak-web-3.0.1 efak
- cd efak
- cd conf
- vim system-config.properties
- 修改zookeeper链接
- 注：cluster1.zk.list=hadoop103:2181,hadoop104:2181,hadoop105:2181这个连接信息应当和kafka对zookeeper的配置信息完全一致
- vim /opt/cloudera/parcels/CDH/lib/kafka/config
- 切记：务必保证kafka/config文件中的 zookeeper.connect配置信息 = cluster1.zk.list
- vim /opt/cloudera/parcels/CDH/lib/kafka/config
- 修改offset存储位置为zk，（也可以是kafka）
- 在已安装好的mysql数据库中新建 ke 数据库
- 配置已安装的mysql数据库作为kafka-eagle的存储库
- 将kafka-eagle的安装路径添加kafka-eagle的环境变量
- vim /etc/profile.d/my_env.sh
- 追加写入如下信息
- # kafkaEFAK
- export KE_HOME=/opt/module/kafka-eagle-bin-3.0.1/efak
- export PATH=$PATH:$KE_HOME/bin
- vim /etc/profile.d/my_env.sh
- 使配置的环境变量生效 source /etc/profile
- 关闭kafka集群
- 在kafka的 bin目录下（cd /opt/cloudera/parcels/CDH/lib/kafka/bin） vim kafka-server-start.sh，启用kafka的端口监听
- 修改如下参数值：
- 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″
- fi
- 修改如下参数值：
- 修改后如下图
- 将kafka修改后的配置文件分发给其他几台服务器
- 分发完毕后启动kafka集群
- 回到安装kafka-eagle的服务器，执行 ke.sh start 命令，启动 kafka-eagle
- 网页端输入 hadoop103:8048 默认账号密码 admin/123456
作者 admin
张宴银，大数据开发工程师