kafka图形管理工具CMAK(Kafka Manager)安装及使用

0    183    1

Tags:

👉 本文共约1783个字,系统预计阅读时间或需7分钟。

简介

kafka-manager 项目地址:https://github.com/yahoo/kafka-manager

为了简化开发者和服务工程师维护Kafka集群的工作,yahoo构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager,现已更名为CMAK(Cluster Manager for Apache Kafka, previously known as Kafka Manager)。主要是因为误用了 Apache 的商标,所以才从 kafka-manager 改名为 CMAK。

这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时,这个管理工具也是一个非常好的可以快速浏览这个集群的工具,有如下功能:

1.管理多个kafka集群
2.便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)
3.选择你要运行的副本
4.基于当前分区状况进行
5.可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)
6.删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=true)
7.Topic list会指明哪些topic被删除(在0.8.2以上版本适用)
8.为已存在的topic增加分区
9.为已存在的topic更新配置
10.在多个topic上批量重分区
11.在多个topic上批量重分区(可选partition broker位置)

CMAK is a tool for managing Apache Kafka clusters。

本人提供Oracle、MySQL、PG等数据库的培训和考证业务,私聊QQ646634621或微信db_bao,谢谢!

安装

安装java 11

下载:https://www.oracle.com/java/technologies/downloads/

Java 11 下载:https://www.oracle.com/java/technologies/downloads/#java11

CMAK需要最低java 11版本,建议安装java 11,我安装java 18后启动报错,安装java 11需要浏览器获取下载地址:

安装zk

参考:https://www.xmmup.com/anzhuangzookeeper.html

ZK最低为3.5版本。

安装CMAK

在 3.0.0.2 版本之前,kafka-manager 是不提供现成的编译包的,需要我们自己编译打包。在 3.0.0.2 版本之后我们可以直接下载编译后的 zip 包即可。

下载地址:https://github.com/yahoo/CMAK

web登陆地址:http://192.168.1.35:9000/

kafka图形管理工具CMAK(Kafka Manager)安装及使用

使用

参考:https://www.cnblogs.com/dadonggg/p/8205302.html

可以通过 Add Cluster 菜单创建我们的 Kafka 集群:

img

注意的的是 Cluster Zookeeper Hosts 要配置 Kafka 在 ZooKeeper 中的 NameSpace,在这我们是 kafka,具体取决于 Kafka 的配置:

看到如下页面表示我们已经创建好集群了:

img

如果你遇到报如下错误:

那么你需要升级 Zookeeper 到 3.5+ 版本。

创建成功后,你就可以看到你的 Kafka 信息:

img

开机启动

错误解决

将kafka的地址和主机名解析加入/etc/hosts文件

否则会报类似错误:Couldn't resolve server lhrkafka:9092 from bootstrap.servers as DNS resolution failed for lhrkafka 和 “Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers”

JMX

kafka图形管理工具CMAK(Kafka Manager)安装及使用

kafka服务必需要开启JMX,否则在下一步启动kafka-manager时会出现:
java.lang.IllegalArgumentException: requirement failed: No jmx port but jmx polling enabled!

解决:在bin/kafka-server-start.sh前面加上如下代码export JMX_PORT=9999,然后重启kafka:

docker使用kafka manager

标签:

头像

小麦苗

学习或考证,均可联系麦老师,请加微信db_bao或QQ646634621

您可能还喜欢...

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

2 × 4 =

 

嘿,我是小麦,需要帮助随时找我哦
  • 18509239930
  • 个人微信

  • 麦老师QQ聊天
  • 个人邮箱
  • 点击加入QQ群
  • 个人微店

  • 回到顶部
返回顶部