在Window下安装kafka-manager
发布日期:2021-04-30 21:00:30 浏览次数:152 分类:精选文章

本文共 1695 字,大约阅读时间需要 5 分钟。

Kafka Manager 简介

Kafka Manager 是一个由 Yahoo 开发的基于 Web 的工具,专为简化 Kafka 集群的维护工作而设计。它可以帮助开发者和服务工程师快速发现集群中 topic 和分区的分布情况,并提供多项管理功能。以下是 Kafka Manager 的主要功能特点:

  • 支持管理多个 Kafka 集群
  • 提供便捷的集群状态检查功能,包括 topics、brokers、备份分布和分区分布
  • 允许用户选择并运行所需的副本
  • 支持基于当前分区状况进行副本重新分配
  • 允许用户配置并创建新的 topic(0.8.1.1 和 0.8.2 的配置可能有所不同)
  • 支持删除 topic(仅在 0.8.2 及以上版本,且需在 broker 配置中启用 delete.topic.enable=true)
  • Topic 列表可指明已删除的 topic(仅适用于 0.8.2 及以上版本)
  • 支持为已有 topic 增加分区
  • 支持为已有 topic 更新配置
  • 允许在多个 topic 上批量重分区
  • 允许在多个 topic 上批量重分区(可选 broker 位置)
  • 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/

    上一篇:Deque接口
    下一篇:Java多线程02:线程的同步和死锁+综合实战

    发表评论

    最新留言

    初次前来,多多关照!
    [***.217.46.12]2026年05月31日 13时22分24秒