kafka 监控工具--CMAK

2023-11-19

CMAK (previously known as Kafka Manager) is a tool for managing Apache Kafka clusters. See below for details about the name change 摘自cmak gtihub

大意就是cmak 旧称为大家熟悉的kafka-manager,同样也是管理Apache Kafka集群的工具。为啥改名呢?主要是因为误用了 Apache 的商标,所以才从 kafka-manager 改名为 CMAK。安装方式大同小异,仅有几处需要注意的地方。话不多说,下面开干。

  1. 首先,我们从github下载安装包,最新版本是3.0.0.6,一般来说下载编译好的zip包就行,如果有特殊需求,可以自己下载源码编译安装

  1. 安装要求

cmak至少要jdk11+以上,本文使用的是jdk17.0.5版本

kafka至少是0.8版本以上,本文使用的是kafka-2.1.1

  1. 创建cmak用户,解压安装包,授权,修改配置文件

修改第28行的zk配置,上面的kafka-manager配置后面会废弃

  1. 启动服务

这边推荐用systemd来管理启动

vi /usr/lib/systemd/system/cmak.service

[Unit]

Description=Kafka Manager ( CMAK )

Requires=network.target

After=network.target

[Service]

Type=simple

User=cmak

Group=cmak

WorkingDirectory=/code/cmak

ExecStart=/code/cmak/bin/cmak -Dpidfile.path=/code/cmak/cmak.pid -Dhttp.port=8080

#这边-Dhttp.port指定服务端口是8080,默认端口是9000

ExecStop=kill $(cat /lingtian/code/cmak/cmak.pid)

Restart=always

[Install]

WantedBy=multi-user.target

systemctl daemon-reload && systemctl start cmak

  1. 启动后发现前端加载异常,服务有报错日志:

查找资料发现,是jdk17的兼容性问题,需要增加启动参数,修改systemd的配置如下:

ExecStart后面增加-J--add-opens=java.base/sun.net.www.protocol.file=ALL-UNNAMED -J--add-exports=java.base/sun.net.www.protocol.file=ALL-UNNAMED

ExecStart=/code/cmak/bin/cmak -Dpidfile.path=/code/cmak/cmak.pid -Dhttp.port=8080 -J--add-opens=java.base/sun.net.www.protocol.file=ALL-UNNAMED -J--add-exports=java.base/sun.net.www.protocol.file=ALL-UNNAMED

  1. 再次启动服务,进入页面正常。

  1. 添加集群,操作和kafka-manager一样:

但是,在保存的时候有报错:

提示/kafka-manager/mutex报错,查资料后发现,2种解决方案,有说zk版本过低需要升级,这个比较麻烦,就直接否决了。第二种是手动创建zk目录,包着试试看的态度,操作了一下:

ls /kafka-manager

create /kafka-manager/mutex ""

create /kafka-manager/mutex/locks ""

create /kafka-manager/mutex/leases ""

ls /kafka-manager

重新添加集群后,成功了!

总结下,这边遇到的就2个问题:

  1. 静态资源问题

! @807hb0egl - Internal server error, for (GET) [/assets/stylesheets/index.min.css] ->

play.api.UnexpectedException: Unexpected exception[RuntimeException: java.lang.IllegalAccessError: class p

lay.utils.Resources$ (in unnamed module @0x93c2679) cannot access class sun.net.www.protocol.file.FileURLC

onnection (in module java.base) because module java.base does not export sun.net.www.protocol.file to unna

med module @0x93c2679]

2.zk缺少目录的问题

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

kafka 监控工具--CMAK 的相关文章

随机推荐

  • 谁能告诉我war包的作用及使用方法。。。。。。

    链接地址 http zhidao baidu com link url iliyTcmsTKb1K4gHMtWUsRIBaXglyOKIQsWwdrgvydvnaUHLe0KEoHvLVz8tLYCjZmvAebFC3srXZEbhW AV
  • Metap:希望通过利用 AI 功能来改变 Metaverse 游戏生态系统

    元宇宙是一个概念 它只会随着时间的推移和让更多的人了解后而越来越受欢迎 因此 了解元宇宙能够更好地利用这种新技术的某些项目是很重要的 能够做到这一点的 一个特殊领域 游戏世界 元宇宙与游戏的关系 将元宇宙的功能与游戏空间放在一起使用并不是一
  • 硬件接口引脚定义(持续更新)

    英文各类硬件接口定义网站 https pinouts ru conn 1 SATA接口引脚定义 2 mSATA接口引脚定义 3 各类USB接口引脚定义 引脚 功能 接线颜色 备注 1 VCC 红色 电源正极 2 Data DM 白色 数据
  • ubuntu配置环境重要网址

    ping不通百度且报错 ping www baidu com Temporary failure in name resolution 的解决方案 https blog csdn net yulei qq article details 1
  • C语言在线代码运行编译工具推荐

    C语言在线运行编译 是一款可在线编程编辑器 在编辑器上输入C语言代码 点击运行 可在线编译运行C语言 C语言代码在线运行调试 C语言在线编译 可快速在线测试您的C语言代码 在线编译C语言代码发现是否存在错误 如果代码测试通过 将会输出编译后
  • V2017+CMake+DCMTK编译安装帮助文档

    转载自https blog csdn net annjeff article details 80899762 一 前言 最近由于项目需要 开始接触DCMTK库 作为一个小白在网上一顿狂搜 看了几天的CSDN博客 终于有了一点头绪 在这个过
  • rpc、gRPC快速入门,python调用,protobuf协议

    什么是rpc grpc又是什么 什么是RPC 远程过程调用协议RPC Remote Procedure Call Protocol RPC是指远程过程调用 也就是说两台服务器A B 一个应用部署在A服务器上 想要调用B服务器上应用提供的函数
  • JavaScript 记录易错点

    1 判断是否是数组的方法 Array isArray 2 获取数组长度用属性 length 不是 length 3 数组添加或删除元素 arrayObject splice index howmany item1 itemX index 必
  • docker 部署springboot(成功、截图)

    1 新建sringboot工程并打包 2 编写Dockerfile文件 基础镜像使用java FROM openjdk 8 作者 MAINTAINER feng VOLUME 指定了临时文件目录为 tmp 其效果是在主机 var lib d
  • 出行者信息服务器,出行者信息服务系统解析.ppt

    出行者信息服务系统解析 ppt ppt 制作 陈倩 ppt 审查 侯湘怡 讲解人 张怀韧 引言 出行者信息服务系统 一 出行者信息服务系统综述 二 出行者信息系统的系统构成及结构框架 三 出行者信息系统的作用 特点与效果 四 出行者信息系统
  • Databend 存储架构总览

    目的 通过本篇文章带大家理解一下 Databend 的存储结构 Databend 内置的 Table 引擎为 Fuse table engine 也是接下来要花重点篇幅要讲的 另外 Databend 还支持外置的 Hive table 及
  • win10病毒和威胁防护无法重新启动解决方法

    1 检查电脑中是否安装了任何的第三方反病毒软件 例如 360 腾讯电脑管家等 如果有的话 麻烦您将其卸载 卸载完毕后重启设备 再看一下病毒和威胁防护能否正常启动 2 按 Windows 徽标键 X 启动 Windows PowerShell
  • nofollow标签的作用 nofollow标签添加方法

    nofollow标签的作用 nofollow标签添加方法 nofollow标签是seo优化常用的一个标签 它的作用是告诉搜索引擎不要追踪这个链接 也就是阻止搜索引擎向这个网页或链接传递权重 nofollow有两种写法 1 将 nofollo
  • 第三章. Pandas入门—索引设置

    第三章 Pandas入门 3 8 索引设置 1 索引的作用 1 更方便的查询数据 2 使用索引可以提升查询性能 如果索引是唯一的 Pandas会使用哈希表优化 查找数据的时间复杂度为O 1 如果索引不是唯一的 但是有序 Pandas会使用二
  • 梯度下降函数理解

    r d 可以理解为有d的参数进行约束 或者 D 向量有d个维度 咱们将楼主的给的凸优化结构细化一点 别搞得那么抽象 不好解释 其中 咱们可以令 f ok 这个先介绍到这里 至于f x 为什么用多项式的方式去模拟 相信也是很多人的疑问 很简单
  • 组织关系图谱

    div style width 100 height 800px div
  • git强制提交本地分支覆盖掉远程分支

    语法比较简单 命令如下 git push origin 分支名 force 举个栗子 git push origin V2 2 3 force 运行结果 Total 0 delta 0 reused 0 delta 0 To http 19
  • golang-bufio 缓冲扫描

    前面两篇博客 介绍了 bufio 包中的缓冲读和写 bufio go 下面再来介绍一下缓冲扫描 scan go 这个扫描的是用来对缓存读的更高级封装 提供了一些更易用的方法 缓冲扫描 Scanner 提供了一个方便的接口来读取数据 例如使用
  • flask-会话机制

    使用flask bootstrap 步骤 1 pip install flask bootstrap 2 进行配置 from flask bootstrap import Bootstrap bootstrap Bootstrap 在 in
  • kafka 监控工具--CMAK

    CMAK previously known as Kafka Manager is a tool for managing Apache Kafka clusters See below for details about the name