kafka可视化web管理工具-KafkaMmap

不管现实多么惨不忍睹,都要持之以恒地相信,这只是黎明前短暂的黑暗而已。不要惶恐眼前的难关迈不过去,不要担心此刻的付出没有回报,别再花时间等待天降好运。真诚做人,努力做事!你想要的,岁月都会给你。kafka可视化web管理工具-KafkaMmap,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文

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发送字符串消息)
  • 功能截图

截图

添加集群

添加集群

集群管理

集群管理

broker

broker

主题管理

主题管理

消费组

消费组

查看消费组已订阅主题

消费组详情

topic详情——分区

topic详情——分区

topic详情——broker

topic详情——broker

topic详情——消费组

topic详情——消费组

topic详情——消费组重置offset

topic详情——消费组重置offset

topic详情——配置信息

topic详情——配置信息

生产消息

消费消息

消费消息

消费消息

延迟消息

延迟消息

协议与条款

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

依赖环境

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

Docker方式安装

环境变量

参数 含义
DEFAULT_USERNAME 初始登录账号
DEFAULT_PASSWORD 初始登录密码
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

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之家整理,本文链接:https://www.bmabk.com/index.php/post/160276.html

(0)
飞熊的头像飞熊bm

相关推荐

发表回复

登录后才能评论
极客之家——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!