2021-11-12

前言

之前一直用雅虎的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/