前言
之前一直用雅虎的Kafka-Manger 去管理Kafka,后面发现 kafka-eagle
也可以实现,所以尝试搭建一下 kafka-eagle
并作下比较 看有什么不同点。
部署
(1)先安装JDK8:
https://mirrors.tuna.tsinghua.edu.cn/AdoptOpenJDK/
(2)下载安装包安装
https://github.com/smartloli/kafka-eagle-bin
(3)加环境变量
vi /etc/profile
# 在profile文件中添加
export KE_HOME=/mydata/kafka/kafka-eagle-web-2.0.5
export PATH=$PATH:$KE_HOME/bin
# 使修改后的profile文件生效
source /etc/profile
我们的存储使用 sqlite,当然你可以改为Mysql,修改配置文件$KE_HOME/conf/system-config.properties
,主要是修改Zookeeper的配置和数据库配置。
######################################
# multi zookeeper & kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=localhost:2181
######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048
######################################
# kafka sqlite jdbc driver address
######################################
kafka.eagle.driver=org.sqlite.JDBC
kafka.eagle.url=jdbc:sqlite:/hadoop/kafka-eagle/db/ke.db
kafka.eagle.username=root
kafka.eagle.password=www.kafka-eagle.org
######################################
# kafka mysql jdbc driver address
######################################
#kafka.eagle.driver=com.mysql.cj.jdbc.Driver
#kafka.eagle.url=jdbc:mysql://localhost:3306/ke?useUnicode=true&characterEncoding=UTF-#8&zeroDateTimeBehavior=convertToNull
#kafka.eagle.username=root
#kafka.eagle.password=root
进行启动:
$KE_HOME/bin/ke.sh start
常用命令
# 停止服务
$KE_HOME/bin/ke.sh stop
# 重启服务
$KE_HOME/bin/ke.sh restart
# 查看服务运行状态
$KE_HOME/bin/ke.sh status
# 查看服务状态
$KE_HOME/bin/ke.sh stats
# 动态查看服务输出日志
tail -f $KE_HOME/logs/ke_console.out
启动成功可以直接访问,输入账号密码admin:123456
,访问地址:http://192.168.5.78:8048/