[大数据] Kafka Eagle安装与使用

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> Kafka Eagle安装与使用 -> 正文阅读

[大数据]Kafka Eagle安装与使用

前言

kafka集群在生产运行过程中，为了方便运维人员对集群进行管理，可以使用Kafka Eagle，比如当运维人员想知道当前的kafka集群创建了多少个topic，集群中broker的数量，各个topic的分区、副本情况等，如果像之前那样使用命令的方式进行查看，必然会非常麻烦；

kafka-eagle概述

可视化界面操作，更加方便运维；
集群的topic信息一览无余，集群中各个节点的健康状况可以很方便的看到；
可以通过该工具管理各个topic，比如创建新的topic等；

前置准备

1、提前安装好zk并启动服务；
2、提前安装好kafka集群并启动集群服务；
3、上传kafka eagle 安装包到指定的目录；

在这里插入图片描述
kafka eagle 官网地址：https://www.kafka-eagle.org/

安装与搭建步骤

1、解压安装包

tar -zxvf kafka-eagle-bin-2.0.8.tar.gz

在这里插入图片描述

进入刚才解压的目录，继续解压里面的efak-web包，这个包才是最终的安装使用的

2、修改配置文件

在这里插入图片描述

修改 system-config.properties 这个配置文件，根据个人的集群情况，其主要要修改的内容如下：

efak.zk.cluster.alias=cluster1
cluster1.zk.list=ZK所在的IP地址:2181

# 配置 mysql 连接
efak.driver=com.mysql.jdbc.Driver
efak.url=jdbc:mysql://mysql服务所在IP:3306/ke?useUnicode=true&characterEncoding=UT
F-8&zeroDateTimeBehavior=convertToNull
efak.username=root
efak.password=123456

这里提前创建一个名叫ke的数据库，和配置文件中的数据库连接信息保持一致

在这里插入图片描述

3、将kafka eagle配置到环境变量

vi /etc/profile

将上面的安装包的目录配置到环境变量中，配置完毕后，注意 source一下

export KE_HOME=/usr/local/soft/eagle/kafka-eagle-bin-2.0.8/efak-web-2.0.8
export PATH=$PATH:$KE_HOME/bin

4、启动kafka eagle服务

首先确保已经启动kafka集群
在这里插入图片描述

接着启动 kafka eagle，进入到kafka eagle目录的bin目录下，执行启动脚本即可

bin/ke.sh start

看到下面的输出内容，说明成功启动了
在这里插入图片描述

5、按照输出的内容，访问web页面

初始化账户和密码为： admin/123456

在这里插入图片描述

登录成功后，来到如下的页面，可以很方便的看到之前我们在集群中创建的各个topic，比如集群中有几个broker，几个topic，连接的zk信息，某个topic的分区、副本数，isr情况，甚至可以直接通过可视化界面像之前使用命令那样创建topic等，这里就不再一一赘述了，有兴趣的同学可以自行操作感受一下

在这里插入图片描述