本文概览:介绍Kafka Eagle的部署和简单实用

1 部署

1、下载地址

http://download.smartloli.org/

1

github地址

https://github.com/smartloli/kafka-eagle

2、配置环境变量

sudo vi /etc/profile,添加如下内容:

执行

3、配置zk地址

system-config.properties 进行如下

4、初始化数据库

(1)配置文件

  • driver,是mysql的driver

(2)建立数据库ke。

(3)导入sql

在老版本中的解压目录中的sql文件夹下面有ke.sql文件,但是新版本(当前使用的是-1.2.1版本)会在启动时自动执行sql的,所以就没有再提供ke.sql了。

5、执行启动命令

执行完成之后,如下图

1

6、访问  http://127.0.0.1:8048/ke

用户名:admin ,密码:123456

52735179

2 使用

2.1 Topic

2.1.1 创建出主题

2

2.1.2 创建消息

3

2.1.3 查看消息

执行

结果如下图

60735933

2.2 Consumer

2.2.1 offsets详情

字段说明:

  • Partition  分区ID,从0开始
  • LogSize  消息总个数
  • Offset  偏移量位置,第几个消息
  • Lag    阻塞的消息个数
  • Owner 负责该分区的消费者的IP

Snip20180511_110

 

参考资料

官网文档:https://ke.smartloli.org/2.Install/1.Env.html

 

 

分类&标签