给编程插上翅膀,给kafka装上导航。
kafka map
是使用Java8
和React
给Apache Kafka
开发的一款web ui工具。
通过这款工具可以很方便直观的查看Broker、 topics、 partitions、consumers等信息,以及查看Topic中的消息。
目前支持的功能有:
- 多集群管理
- topic监控 —— 查看分区数量、副本数量、存储大小、offset
- topic管理 —— 创建、删除、扩容
- broker查看 —— Partitions as Leader、 Partitions as Follower
- consumer管理(查看、删除)
- 重置offset
- 消费消息 —— 支持String和json方式展示
如您需要在企业网络中使用 kafka-map
,建议先征求 IT 管理员的同意。下载、使用或分发 kafka-map
前,您必须同意 协议 条款与限制。本项目不提供任何担保,亦不承担任何责任。
- Java8 或更高版本
- Apache Kafka 1.1.0 或更高版本
下载
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
# 启动
java -jar kafka-map.jar
在 /etc/systemd/system/
下创建 kafka-map.service
并写入以下内容
根据自身实际情况修改 WorkingDirectory 和 ExecStart下面的程序所在目录及java
[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
端口即可访问。
不想使用8080端口怎么办?
在启动命令上增加 --server.port=1234
即可修改端口为 1234
。
# 示例
java -jar kafka-map.jar --server.port=1234