kafka-eagle 管理工具

kafka-eagle 管理工具 前言

之前一直用雅虎的Kafka-Manger 去管理Kafka，后面发现 kafka-eagle 也可以实现，所以尝试搭建一下 kafka-eagle 并作下比较 看有什么不同点。

官网： https://www.kafka-eagle.org/

部署

（1）先安装JDK8:
https://mirrors.tuna.tsinghua.edu.cn/AdoptOpenJDK/

（2）下载安装包安装
https://codeload.github.com/smartloli/kafka-eagle-bin/tar.gz/v2.0.8

（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:/usr/local/kafka-eagle/efak-web/db/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/

修改默认密码

vim …/conf/system-config.properties

kafka.eagle.username=root
kafka.eagle.password=smartloli

也可以防火墙控制源:

## 不被安全组扫到，准许源
-A INPUT -s 10.19.192.65/32 -p tcp -m state --state NEW -m tcp --dport 8048 -j ACCEPT