kafka可视化web管理工具-KafkaMmap

偏执的太偏执、 2024-03-27 09:38 60阅读 0赞

## kafka可视化web管理工具-KafkaMmap ##

使用过kafka的小伙伴应该都知道kafka本身是没有管理界面的，所有操作都需要手动执行命令来完成。但有些命令又多又长，如果没有做笔记，别说是新手，就连老手也不一定能记得住，每次想要使用的时候都要上网搜索一下。有些崇尚geek精神的人或许觉得命令行才是真爱，但使用一款好用的可视化管理工具真的可以极大的提升效率。

今天给大家介绍的这款工具叫做kafka-map，是我针对日常工作中高频使用的场景开发的，使用了这款工具之后就不必费心费力的去查资料某个命令要怎么写，就像是：“给编程插上翅膀，给kafka装上导航”。

![image-20221216142646333][]

### kafka-map 简介 ###

> kafka map是使用Java11和React开发的一款kafka可视化工具。

目前支持的功能有：

*  多集群管理
 *  集群状态监控（分区数量、副本数量、存储大小、offset）
 *  主题创建、删除、扩容（删除需配置delete.topic.enable = true）
 *  broker状态监控
 *  消费者组查看、删除
 *  重置offset
 *  消息查询（支持String和json方式展示）
 *  发送消息（支持向指定的topic和partition发送字符串消息）
 *  功能截图

### 截图 ###

#### 添加集群 ####

![添加集群][2ec78e12251a9a197c10bdd20b5e2681.png]

#### 集群管理 ####

![集群管理][52b5f1adb935b2c8b928cad3e9ab5595.png]

#### broker ####

![broker][]

#### 主题管理 ####

![主题管理][1eea673956f0ccfc5c39ee0507c2eaf3.png]

#### 消费组 ####

![消费组][35dfb89f582e2a46584563de78fa7b32.png]

#### 查看消费组已订阅主题 ####

![消费组详情][28896af0b5c976f6b45eb19c4994ee51.png]

#### topic详情——分区 ####

![topic详情——分区][topic]

#### topic详情——broker ####

![topic详情——broker][topic_broker]

#### topic详情——消费组 ####

![topic详情——消费组][topic 1]

#### topic详情——消费组重置offset ####

![topic详情——消费组重置offset][topic_offset]

#### topic详情——配置信息 ####

![topic详情——配置信息][topic 2]

#### 生产消息 ####

![消费消息][ba606ae55e766ddeabf4e1e6f065d306.png]

#### 消费消息 ####

![消费消息][079999c59205987d45e6dc9a2ec7384c.png]

#### 延迟消息 ####

![延迟消息][53572629ea898f3a421e8e88bfbc1ef6.png]

### 协议与条款 ###

如您需要在企业网络中使用 `kafka-map` ，建议先征求 IT 管理员的同意。下载、使用或分发 `kafka-map` 前，您必须同意 [协议][Link 1] 条款与限制。本项目不提供任何担保，亦不承担任何责任。

### 依赖环境 ###

*  Java11 或更高版本
 *  Apache Kafka 1.1.0 或更高版本

### Docker方式安装 ###

#### 环境变量 ####

<table> 
 <thead> 
  <tr> 
   <th>参数</th> 
   <th>含义</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>DEFAULT_USERNAME</td> 
   <td>初始登录账号</td> 
  </tr> 
  <tr> 
   <td>DEFAULT_PASSWORD</td> 
   <td>初始登录密码</td> 
  </tr> 
 </tbody> 
</table>

docker run -d \
        -p 8080:8080 \
        -v `pwd`/data:/usr/local/kafka-map/data \
        -e DEFAULT_USERNAME=admin \
        -e DEFAULT_PASSWORD=admin \
        --name kafka-map \
        --restart always dushixiang/kafka-map:latest

### 原生方式安装 ###

下载

wget https://github.com/dushixiang/kafka-map/releases/latest/download/kafka-map.tgz

解压

tar -zxvf kafka-map.tgz -C /usr/local/

#### 前台运行 ####

# kafka-map文件夹
    cd /usr/local/kafka-map
    # 根据需求自行修改配置
    vi application.yml
    # 启动
    java -jar kafka-map.jar

#### 系统服务方式运行 ####

cat <<EOF >> /etc/systemd/system/kafka-map.service
    [Unit]
    Description=kafka map service
    After=network.target
    
    [Service]
    WorkingDirectory=/usr/local/kafka-map
    ExecStart=/usr/bin/java -jar /usr/local/kafka-map/kafka-map.jar
    Restart=on-failure
    
    [Install]
    WantedBy=multi-user.target

重载系统服务&&设置开机启动&&启动服务&&查看状态

systemctl daemon-reload
    systemctl enable kafka-map
    systemctl start kafka-map
    systemctl status kafka-map

#### 使用 ####

接下来使用浏览器打开服务器的 `8080` 端口即可访问。

### FAQ ###

不想使用8080端口怎么办？

````

在启动命令上增加 --server.port=1234 即可修改端口为 1234。
    # 示例
    java -jar kafka-map.jar --server.port=1234

[image-20221216142646333]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/7e9e8322c7694ad8b9187e3a0dc32dcd.png
[2ec78e12251a9a197c10bdd20b5e2681.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/b290e9b5c7b74ae6ad7da5e032b75490.png
[52b5f1adb935b2c8b928cad3e9ab5595.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/71092dfe79654eb2b31abf2d8d66fc9e.png
[broker]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/a2fbbd4861964f10b16ba77a412cb932.png
[1eea673956f0ccfc5c39ee0507c2eaf3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/8d8293bb57cd4170ae23f6c2982c1136.png
[35dfb89f582e2a46584563de78fa7b32.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/f8d7ae5211fa4241b06883951529456b.png
[28896af0b5c976f6b45eb19c4994ee51.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/0c5f2747fa44418ea38e7386b90f704f.png
[topic]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/d1ea50cd05324c4e84d42b9169585b21.png
[topic_broker]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/67d2e257f69941b593ca62f394934005.png
[topic 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/a69720c8f63f49dc99e482475e5614fd.png
[topic_offset]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/433eb1683679457a9bc2e640481606bc.png
[topic 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/d3125540e37948b4a22a5ac205fb8852.png
[ba606ae55e766ddeabf4e1e6f065d306.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/85bbd7d37cdd4d7b80a47b19f5dde5cc.png
[079999c59205987d45e6dc9a2ec7384c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/eb63e409ae234f4686fbc2de8b5eb1a0.png
[53572629ea898f3a421e8e88bfbc1ef6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/73571e1b5e4545e7988a4496a9468e0e.png
[Link 1]: https://gitee.com/dushixiang/kafka-map/blob/master/LICENSE