本文共 1695 字,大约阅读时间需要 5 分钟。
Kafka Manager 简介
Kafka Manager 是一个由 Yahoo 开发的基于 Web 的工具,专为简化 Kafka 集群的维护工作而设计。它可以帮助开发者和服务工程师快速发现集群中 topic 和分区的分布情况,并提供多项管理功能。以下是 Kafka Manager 的主要功能特点:
Kafka Manager 的项目地址:github.com/Netflix/KafkaManager
安装
1. 安装环境要求
- Java 1.8
- Scala
- SBT
2. 修改配置
打开 application.conf 文件,修改其中的配置信息(主要是连接 Zookeeper 服务的端口):
# 配置 kafka-manager.zkhosts="node5.sdp.cn:2181,node6.sdp.cn:2181"
3. 编译
进入 Kafka Manager 目录,在命令窗口中输入:
sbt clean dist
下载依赖的 jar 包,完成后会自动生成工作目录。为了加快下载速度,可以在 SBT 配置中添加阿里云的私服地址。
阿里云网络环境较为复杂,建议在 sbt\conf\ 目录下创建 repo.properties 文件,内容如下:
# 仓库配置[repositories]localaliyun: http://maven.aliyun.com/nexus/content/groups/public/typesafe: http://repo.typesafe.com/typesafe/ivy-releases/[organization]/[module]/(scala_[scalaVersion]/)(sbt_[sbtVersion]/)[revision]/[type]s/[artifact](-[classifier]).[ext], bootOnlysonatype-oss-releasesmaven-centralsonatype-oss-snapshots
编译完成后,目标目录 target/universal 中会生成一个压缩包 kafka-manager-1.3.3.22.zip。
4. 启动
将压缩包解压到指定目录,并使用以下命令启动 Kafka Manager:
.\bin\kafka-manager
默认端口为 9000,可以通过指定配置文件和端口调整:
.\bin\kafka-manager -Dconfig.file=.\conf\application.conf -Dhttp.port=8080
5. 添加集群
在 Cluster 下拉框中选择 Add Cluster 添加一个集群节点。输入 Cluster Name 和 Cluster Zookeeper Hosts 即可,其他选项默认保存。
6. 查看集群
查看集群状态、查看所有 topic 和查看 topic 消费偏移量等功能均可在界面内完成。
其他操作
打开命令窗口,进入 Kafka Manager 解压目录,输入以下命令:
sbt
初始化工作目录后,输入 compile 进行编译,编译完成后输入 run,即可打开浏览器访问管理界面:http://127.0.0.1:9000/。
发表评论
最新留言
关于作者