安装kafka eagle监控kafka集群
1、下载kafka eagle的压缩包并解压
wget https://github.com/smartloli/kafka-eagle-bin/archive/v1.2.7.tar.gz
解压
tar -zxvf xxx
2、配置环境变量
需要配置JAVA_HOME和KE_HOME的环境变量
在自己的home目录下面的.bash_profile文件里面增加如下内容
export JAVA_HOME=/usr/local/jdk1.8.0_151
#add kafka-eagle
export KE_HOME=/data/ai-system/docker-data/kafka-eagle/kafka-eagle-bin-1.2.7/kafka-eagle-web-1.2.7
PATH=$PATH:$KE_HOME/bin:$JAVA_HOME/bin
export PATH
刷新使之立即生效
source ~/.bash_profile
这里有一定要将JAVA_HOME和KE_HOME export出来，不然后面运行会报错，因为ke.sh里面用到了这两个变量
3、修改配置文件
进入自己安装的kafka eagle的config目录
cd $KE_HOME/conf
vim system-config.properties
######################################
# multi zookeeper&kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
#配置zk集群的
cluster1.zk.list=ip1:2181,ip2:2182,ip3:2183
#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181
######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25
######################################
# kafka eagle webui port
######################################
访问web的端口，注意防火墙
kafka.eagle.webui.port=8048
######################################
# kafka offset storage
######################################
cluster1.kafka.eagle.offset.storage=kafka
#cluster2.kafka.eagle.offset.storage=zk
######################################
# enable kafka metrics
######################################
kafka.eagle.metrics.charts=false
kafka.eagle.sql.fix.error=false
######################################
# kafka sql topic records max
######################################
kafka.eagle.sql.topic.records.max=5000
######################################
# alarm email configure
######################################
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
######################################
# delete 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 driver address
######################################
#我切换了自己mysql,下面用自己的配置的mysql的用户名和密码
kafka.eagle.driver=com.mysql.jdbc.Driver
kafka.eagle.url=jdbc:mysql://mysql_ip:3306/vision_platform?useUnicode: true&characterEncoding: UTF-8
kafka.eagle.username=root
kafka.eagle.password=mysqlpasswd
开启ke.sh的可执行权限
chmod + x $KE_HOME/bin/ke.sh
4、运行ke.sh
| 命令 | 说明 |
|---|---|
| ke.sh start | 启动Kafka Eagle系统 |
| ke.sh stop | 停止Kafka Eagle系统 |
| ke.sh restart | 重启Kafka Eagle系统 |
| ke.sh status | 查看Kafka Eagle系统运行状态 |
| ke.sh stats | 统计Kafka Eagle系统占用Linux资源情况 |
| ke.sh find [ClassName] | 查看Kafka Eagle系统中的类是否存在 |
运行成功后如下：
登录地址：ip:8048/ke
用户名:admin
密码：123456
这个用户名和密码我找了半天~~
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/111204.html原文链接：https://javaforall.net
