本文概览：介绍Kafka Eagle的部署和简单实用
1 部署
1、下载地址
http://download.smartloli.org/
github地址
https://github.com/smartloli/kafka-eagle
2、配置环境变量
sudo vi /etc/profile，添加如下内容：
|
1 |
export KE_HOME=/Users/wuzhonghu/local/kafka-eagle-bin-1.2.1/kafka-eagle-web-1.2.1 |
执行
|
1 |
source /etc/profile |
3、配置zk地址
system-config.properties 进行如下
|
1 2 |
kafka.eagle.zk.cluster.alias=cluster1 cluster1.zk.list=localhost:2181 |
4、初始化数据库
（1）配置文件
- driver，是mysql的driver
|
1 2 3 4 |
kafka.eagle.driver=com.mysql.jdbc.Driver kafka.eagle.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull kafka.eagle.username=root kafka.eagle.password=123456 |
（2）建立数据库ke。
|
1 |
create dabase ke |
（3）导入sql
在老版本中的解压目录中的sql文件夹下面有ke.sql文件，但是新版本（当前使用的是-1.2.1版本）会在启动时自动执行sql的，所以就没有再提供ke.sql了。
5、执行启动命令
|
1 |
sh bin/ke.sh start |
执行完成之后，如下图
6、访问 http://127.0.0.1:8048/ke
用户名：admin ，密码：123456
2 使用
2.1 Topic
2.1.1 创建出主题
2.1.2 创建消息
2.1.3 查看消息
执行
|
1 |
SELECT * FROM "ketest" WHERE "partition" IN (0) limit 10 |
结果如下图
2.2 Consumer
2.2.1 offsets详情
字段说明：
- Partition 分区ID,从0开始
- LogSize 消息总个数
- Offset 偏移量位置，第几个消息
- Lag 阻塞的消息个数
- Owner 负责该分区的消费者的IP
参考资料
官网文档：https://ke.smartloli.org/2.Install/1.Env.html
