kafka-eagle 使用
docker
下载
docker pull nickzurich/kafka-eagle
准备system-config.properties配置文件
######################################
# multi zookeeper & kafka cluster list
######################################
# kafka.eagle.zk.cluster.alias=cluster1,cluster2
# cluster1.zk.list=tdn1:2181,tdn2:2181,tdn3:2181
# cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.99.100:2181######################################
# zookeeper enable acl
######################################
cluster1.zk.acl.enable=false
cluster1.zk.acl.schema=digest
cluster1.zk.acl.username=test
cluster1.zk.acl.password=test123######################################
# broker size online list
######################################
cluster1.kafka.eagle.broker.size=20######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048######################################
# kafka jmx acl and ssl authenticate
######################################
cluster1.kafka.eagle.jmx.acl=false
cluster1.kafka.eagle.jmx.user=keadmin
cluster1.kafka.eagle.jmx.password=keadmin123
cluster1.kafka.eagle.jmx.ssl=false
cluster1.kafka.eagle.jmx.truststore.location=/Users/dengjie/workspace/ssl/certificates/kafka.truststore
cluster1.kafka.eagle.jmx.truststore.password=ke123456######################################
# kafka offset storage
######################################
cluster1.kafka.eagle.offset.storage=kafka
cluster2.kafka.eagle.offset.storage=zk######################################
# kafka metrics, 15 days by default
######################################
kafka.eagle.metrics.charts=true
kafka.eagle.metrics.retain=15######################################
# kafka sql topic records max
######################################
kafka.eagle.sql.topic.records.max=5000######################################
# delete kafka topic token
######################################
kafka.eagle.topic.token=keadmin######################################
# kafka sasl authenticate
######################################
cluster1.kafka.eagle.sasl.enable=false
cluster1.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
cluster1.kafka.eagle.sasl.mechanism=SCRAM-SHA-256
cluster1.kafka.eagle.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="kafka" password="kafka-eagle";
cluster1.kafka.eagle.sasl.client.id=
cluster1.kafka.eagle.blacklist.topics=
cluster1.kafka.eagle.sasl.cgroup.enable=false
cluster1.kafka.eagle.sasl.cgroup.topics=
cluster2.kafka.eagle.sasl.enable=false
cluster2.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
cluster2.kafka.eagle.sasl.mechanism=PLAIN
cluster2.kafka.eagle.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="kafka" password="kafka-eagle";
cluster2.kafka.eagle.sasl.client.id=
cluster2.kafka.eagle.blacklist.topics=
cluster2.kafka.eagle.sasl.cgroup.enable=false
cluster2.kafka.eagle.sasl.cgroup.topics=######################################
# kafka ssl authenticate
######################################
cluster3.kafka.eagle.ssl.enable=false
cluster3.kafka.eagle.ssl.protocol=SSL
cluster3.kafka.eagle.ssl.truststore.location=
cluster3.kafka.eagle.ssl.truststore.password=
cluster3.kafka.eagle.ssl.keystore.location=
cluster3.kafka.eagle.ssl.keystore.password=
cluster3.kafka.eagle.ssl.key.password=
cluster3.kafka.eagle.blacklist.topics=
cluster3.kafka.eagle.ssl.cgroup.enable=false
cluster3.kafka.eagle.ssl.cgroup.topics=######################################
# 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.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
主要修改的配置如下:
# 配置zk
cluster1.zk.list=172.16.253.35:2181
# 配置mysql
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
启动docker
docker run -d --name kafka-eagle \
-p 8048:8048 \
-v /docker/volumes/kafka-eagle/db:/hadoop/kafka-eagle/db \ #把db地址映射到本地
-v /docker/volumes/kafka-eagle/conf/system-config.properties:/kafka-eagle/conf/system-config.properties \ # 此处为本地的system-config.properties配置文件nickzurich/kafka-eagle
启动成功,查看密码
默认都是admin/123456
登录网页
- 访问 127.0.0.1:8048 输入上述密码即可进入
Linux
1.去kafka-eagle官网下载压缩包
http://download.kafka-eagle.org/
2.安装jdk-配置环境变量
3.解压缩kafka-eagle的压缩包
4.给kafka-eagle配置环境变量
export KE_HOME=/usr/local/kafka-eagle
export PATH=$PATH:$KE_HOME/bin
5.修改system-config.properties
# 配置zk
cluster1.zk.list=172.16.253.35:2181
# 配置mysql
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
6.启动
进入bin中
./ke.sh start
kafka-eagle 使用相关推荐
- Kafka 消息监控 - Kafka Eagle
1.概述 在开发工作当中,消费 Kafka 集群中的消息时,数据的变动是我们所关心的,当业务并不复杂的前提下,我们可以使用 Kafka 提供的命令工具,配合 Zookeeper 客户端工具,可以很方便 ...
- Kafka Eagle 源码解读
1.概述 在<Kafka 消息监控 - Kafka Eagle>一文中,简单的介绍了 Kafka Eagle这款监控工具的作用,截图预览,以及使用详情.今天笔者通过其源码来解读实现细节.目 ...
- Kafka 监控 Kafka Eagle 图形化版本
文章目录 一.Kafka Eagle 下载.编译流程 1. Kafka Eagle下载 2. 解压Kafka Eagle 3. 进入解压的目录 4. 编译项目 5. 添加编译环境 6. 运行脚本编译项 ...
- Kafka 监控 Kafka Eagle 精简版本
文章目录 一.Kafka Eagle 下载.编译流程 1. Kafka Eagle下载 2. 解压Kafka Eagle 3. 进入解压的目录 4. 编译项目 5. 添加编译环境 6. 运行脚本编译项 ...
- 基于jmx监控kafka_0542-6.1.0-非安全环境下Kafka管理工具Kafka Eagle安装使用
1.文档编写目的 Fayson在前面的文章介绍了<0374-如何在CDH集群中部署Kafka Manager>,本篇文章Fayson介绍另外一款的监控工具Kafka-eagle,它可以同时 ...
- kafka 集群_Kafka集群监控系统Kafka Eagle部署与体验
Kafka Eagle是一款开源的Kafka集群监控系统 能够实现broker级常见的JMX监控: 能对consumer消费进度进行监控: 能在页面上直接对多个集群进行管理: 安装方式简单,二进制包解 ...
- Kafka eagle 安装
1.下载 eagle 压缩包,上传到 虚拟机node01上 2.加压缩 3.修改配置文件的下面几个地方 kafka.eagle.zk.cluster.alias=cluster1 cluster1.z ...
- 【Kafka】Kafka eagle 监控界面无数据
文章目录 1.背景 1.场景1 8.题外话 本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 可以加我问问题,免费解答,有问题可以先私聊我,本人每天都在线 ...
- 【Kafka】Mac 环境 Kafka诡异问题之kafka eagle 界面无法访问
文章目录 1.背景 2. 解决 本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 可以加我问问题,免费解答,有问题可以先私聊我,本人每天都在线,会帮助需要 ...
- 【kafka】Kafka 可视化工具Kafka Eagle安装和使用
一.背景 Kafka产线环境需要管理的Topic和Consumser越来越多,使用命令行工具进行管理会非常繁杂.因此,大数据平台上需要一套Kafka的管理监控系统,Kafka-Eagle. Kafka ...
最新文章
- 记录每个登陆用户的操作记录
- 14岁初中生3天制成勒索病毒 制作方法或自学而成
- Datagridview 在基于文本的单元格中启用换行,自动调整行高列宽
- JAVA数据类型及字符编码
- android简单项目及代码_Android 开源项目 (AOSP) 代码搜索工具正式发布
- Android Studio 3.1无法导入模块的解决办法
- 模具设计详细流程,建议收藏
- webpack:Error: Compiling RuleSet failed: Exclamation mark separated loader lists has been removed
- Geek生活--netHack
- 【运维】服务器的初步认识
- 实验吧——安全杂项之“Snake”详解
- 博弈论(初级)——数学知识(C++)
- mongodb权限管理篇
- 使用python开发的图形界面的pdf拆分合并工具
- 我的铁人三项训练计划
- 虚拟光驱 daemon tools lite 4.4 下载 2011最新版
- 【滤波】无迹卡尔曼滤波
- 一课时计算机基础教案模板,计算机基础电子教案_初中信息技术教案_模板
- Docker 集群Swarm创建和Swarm Web管理
- PyMol - script
热门文章
- asp.net core linux环境,ASP.NET Core Linux环境安装并运行项目
- java 使用抽象类解决长方形与圆求周长与面积的实现
- 晶体管的工作原理及电流关系
- 开源进度跟踪 33复杂美Chain33
- 自动驾驶 | 全面解读小马智驾的解决方案「AI工程落地」
- Java的IO---File的功能
- 马云的讲话,充满了对金融的“无知与傲慢”!
- PHP 介绍php的一些基本语法,配合wamp,跟着案例来学习GET和POST请求( 非常详细 )
- 这三款可以把图片转换为文字的软件,不容错过
- MongoDB的skip,limit,sort执行顺序,以及aggregate