kafka Eagle
Kafka Eagle是开源的可视化和管理软件。它使您可以查询,可视化,警告和浏览指标,无论它们存储在哪里。它为您提供了将kafka群集数据转换为漂亮的图形和可视化效果的工具。
安装Kafka Eagle
1.下载并安装
您可以在GitHub上下载Kafka Eagle源代码以自己编译或安装,也可以下载二进制.tar.gz文件。
安装注意事项:
我们建议使用官方编译的二进制安装包。
2.安装JDK
如果Linux服务器上存在JDK环境,则可以忽略此步骤,并安装后续步骤。如果没有JDK,参考网上博客安装JDK。
3.解压Kafka
将文件解压至相关目录
1 tar -zxvf kafka-eagle-xxx-bin.tar.gz
如果您以前安装过该版本,请删除修改后的版本,然后重命名当前版本,如下所示:
rm -rf kafka-eagle
mv kafka-eagle-xxx kafka-eagle
然后,配置Kafka Eagle 配置文件
vi /etc/profile
export KE_HOME = /data/soft/new/kafka-eagle
export PATH=$PATH:$KE_HOME/bin
最后,我们使用 . /etc/profile是配置立即生效。
4.配置Kafka Eagle system file
根据自己的Kafka集群的实际情况配置Kafka Eagle,例如Zookeeper地址,Kafka集群的版本类型(低版本为zk,高版本为kafka),启用了安全认证的Kafka集群等。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57 #修改配置文件
vim system-config.properties
#配置文件详情介绍
#kafkazookeeper节点配置属性多个可以添加一个,cluster1
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.163.131:2181
######################################
# zk 线程数量
######################################
kafka.zk.limit.size=25
######################################
# kafka eagle 的端口
######################################
kafka.eagle.webui.port=8048
######################################
# kafka offset storage
######################################
cluster1.kafka.eagle.offset.storage=kafka
######################################
# enable kafka 开启图表
# 及开始sql查询
######################################
kafka.eagle.metrics.charts=true
kafka.eagle.sql.fix.error=true
######################################
# 提醒的email
######################################
kafka.eagle.mail.enable=true
kafka.eagle.mail.sa=alert_sa
kafka.eagle.mail.username=alert_sa@163.com
kafka.eagle.mail.password=mqslimczkdqabbbh
kafka.eagle.mail.server.host=smtp.163.com
kafka.eagle.mail.server.port=25
######################################
# 删除kafka topic 的token
######################################
kafka.eagle.topic.token=keadmin
######################################
# kafka sasl authenticate
######################################
kafka.eagle.sasl.enable=false
kafka.eagle.sasl.protocol=SASL_PLAINTEXT
kafka.eagle.sasl.mechanism=PLAIN
######################################
# kafka jdbc 地址注意可以自己安装数据mysql也可以自带的
######################################
kafka.eagle.driver=org.sqlite.JDBC
kafka.eagle.url=jdbc:sqlite:/kafka/kafka-eagle-bin-1.2.4/kafka-eagle-web-1.2.4/db/ke.db
kafka.eagle.username=root
kafka.eagle.password=smartloli
5.启动Kafka Eagle服务器
在$KE_HOME/bin
目录中,有一个ke.sh
脚本文件。执行以下启动命令:
1
2
3 cd ${KE_HOME}/bin
chmod +x ke.sh
./ke.sh start之后,当重新启动或停止Kafka Eagle服务器时,执行以下命令:
1 | ke.sh restart |
如图: