kafka监控工具EFAK

server/2024/9/24 21:15:24/

kafka监控工具(EFAK)

  • 1、下载
  • 2、解压
  • 3、配置
    • 3.1、安装数据库,需要是mysql,并创建ke数据库
    • 3.2、修改配置文件
  • 4、启动
    • 4.1、启动zookeeper
    • 4.2、启动kafka
    • 4.3、启动EFAK
  • 5、访问http://ip:8048

在这里插入图片描述

在这里插入图片描述

github地址:https://github.com/smartloli/kafka-eagle-bin/

github介绍:https://github.com/smartloli/EFAK

1、下载

官网下载:https://www.kafka-eagle.org/

在这里插入图片描述

github下载地址:https://github.com/smartloli/kafka-eagle-bin/blob/master/efak-web-3.0.2-bin.tar.gz

在这里插入图片描述

2、解压

将下载好的压缩包上传至linux指定位置

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
cd efak-web-3.0.1
  • tar -zxvf kafka-eagle-bin-3.0.1.tar.gz

在这里插入图片描述

在这里插入图片描述

  • tar -zxvf efak-web-3.0.1-bin.tar.gz

在这里插入图片描述

  • cd efak-web-3.0.1

在这里插入图片描述

3、配置

在这里插入图片描述

3.1、安装数据库,需要是mysql,并创建ke数据库

在这里插入图片描述

在这里插入图片描述

3.2、修改配置文件

在这里插入图片描述

1、来到安装目录conf文件夹下:

cd /usr/local/kafka-eagle-bin-3.0.1/efak-web-3.0.1/conf

2、编辑配置文件

vim system-config.properties

3、修改zookeeper配置和mysql连接配置

原zookeeper的相关配置:
在这里插入图片描述
修改后的zookeeper配置

efak.zk.cluster.alias=cluster1,cluster2
cluster1.zk.list=127.0.0.1:2181

在这里插入图片描述

4、修改mysql配置

原mysql配置:
在这里插入图片描述
修改后的mysql配置:

efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai
efak.username=root
efak.password=<你的mysql数据库密码>

5、在/etc/profile配置文件中配置环境变量

vim /etc/profile

在这里插入图片描述

export KE_HOME=/usr/local/kafka-eagle-bin-3.0.1/efak-web-3.0.1
export PATH=$KE_HOME/BIN:$PATH

在这里插入图片描述

source /etc/profile

在这里插入图片描述

4、启动

  • 确保kafka采用zookeeper方式启动(到kafak安装目录的bin文件夹下,先启动zookeeper,在启动kafka,可参考kafka启动)
  • 在EFAK安装目录的bin目录下执行:./ke.shstart(命令使用:ke.sh [start|status|stop|restartlstats])

4.1、启动zookeeper

在这里插入图片描述

kafka_149">4.2、启动kafka

在这里插入图片描述

4.3、启动EFAK

在这里插入图片描述

./ke.sh start

在这里插入图片描述
在这里插入图片描述

5、访问http://ip:8048


http://www.ppmy.cn/server/104321.html

相关文章

JS forEach、every和some

forEach() 从头到尾的遍历的数组&#xff0c;可以改变数组的值。为数组中的每个元素都执行一遍传递给forEach()的回调函数。 var arr [2, 4, 65, 23];var sum 0;arr.forEach(function(value, index, array) {console.log(每个数组元素 value);console.log(每个数组元素的索引…

LeeCode Practice Journal | Day50_Graph01

( LeeCode) 797. 所有的可能路径 题目&#xff1a;797. 所有可能的路径 - 力扣&#xff08;LeetCode&#xff09; 题解&#xff1a;代码随想录 (programmercarl.com) solution DFS public class Solution {public IList<IList<int>> results new List<ILis…

大数据——Flink原理

摘要 Apache Flink是一个框架和分布式处理引擎&#xff0c;用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行&#xff0c;以内存执行速度和任意规模来执行计算。 1. FLink特点 1.1. 事件驱动型(Event-driven) 事件驱动型应用是一类具有状态的应…

virtualbox从u盘启动

1.添加到vboxusers用户组 sudo usermod -G vboxusers -a whoami 2.为u盘设备添加访问权限&#xff0c;注意替换对应的设备文件&#xff0c;我这里是/dev/sdf sudo chmod orw /dev/sdf 3.为u盘创建一个虚拟的硬盘镜像 sudo VBoxManage internalcommands createrawvmdk -fi…

IPC对象通信方式---共享内存 | 网络通信 -编程

共享内存 共享内存机制其允许两个或多个进程共享一个给定的存储区&#xff0c;这一段存储区可以被两个或两个以上的进程映射至自身的地址空间中&#xff0c;一个进程写入共享内存的信息&#xff0c;可以被其他使用这个共享内存的进程&#xff0c;通过一个简单的内存读取错做读…

2024网络安全学习路线 非常详细 推荐学习

关键词&#xff1a;网络安全入门、渗透测试学习、零基础学安全、网络安全学习路线 首先咱们聊聊&#xff0c;学习网络安全方向通常会有哪些问题 1、打基础时间太长 学基础花费很长时间&#xff0c;光语言都有几门&#xff0c;有些人会倒在学习 linux 系统及命令的路上&#…

C++模拟实现priority_queue(优先级队列)

一、priority_queue的函数接口 从上图我们可以看出&#xff0c; priority_queue也是一个容器适配器&#xff0c;我们使用vector容器来模拟实现priority_queue。 namespace bit{#include<vector>#include<functional>template <class T, class Container vector…

MiDaS、ZoeDepth、Depth-Anything ai算法深度图估计

1、MiDaS 参考&#xff1a; https://github.com/isl-org/MiDaS https://pytorch.org/hub/intelisl_midas_v2/ https://colab.research.google.com/github/pytorch/pytorch.github.io/blob/master/assets/hub/intelisl_midas_v2.ipynb#scrollTo5A32CL3tocrZ 代码 import cv2 i…