6 Star 25 Fork 4

dushixiang / kafka-map

Create your Gitee Account
Explore and code with more than 6 million developers,Free private repositories !:)
Sign up
Clone or Download
Cancel
Notice: Creating folder will generate an empty file .keep, because not support in Git
Loading...
README.md

kafka map

English | 简体中文

Add wings to programming and install navigation to kafka

Introduction

kafka-map is a kafka visualization tool developed using Java11 and React.

Supported features:

  • Multi-cluster management.
  • Cluster status monitoring (number of partitions, number of replicas, storage size, offset).
  • Topic create, delete, expansion (delete needs to configure delete.topic.enable = true).
  • Broker status monitoring.
  • Consumer group view and delete.
  • Reset offset.
  • Topic data view and search (Support String and json display).
  • Send message to Topic
  • Delay message (supports 18 levels of delayed messages).

Screenshot

Import cluster

添加集群

Clusters

集群管理

Brokers

broker

Topics

主题管理

Consumer Groups

消费组

Consumer Group Subscription

消费组详情

Topic Partition

topic详情——分区

Topic Brokers

topic详情——broker

Topic Consumer Groups

topic详情——消费组

Topic Consumer Groups Reset Offset

topic详情——消费组重置offset

Topic Configs

topic详情——配置信息

Produce Message

消费消息

Consume Message

消费消息

Delay Message

延迟消息

Disclaimer

Developers wishing to use kafka-map within a corporate network are advised to seek approval from their administrators or management before using the tool. By downloading, using, or distributing kafka-map, you agree to the LICENSE terms & conditions. No warranty or liability is provided.

Required

  • Java11 or higher
  • Apache Kafka 1.1.0 or higher

install by docker

end

Param Description
DEFAULT_USERNAME Initial login username
DEFAULT_PASSWORD Initial login password
docker run -d \
    -p 8080:8080 \
    -v /opt/kafka-map/data:/usr/local/kafka-map/data \
    -e DEFAULT_USERNAME=admin \
    -e DEFAULT_PASSWORD=admin \
    --name kafka-map \
    --restart always dushixiang/kafka-map:latest

install by native

download

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

unzip

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

Running in the foreground

# kafka-map dir
cd /usr/local/kafka-map
# Modify the configuration according to your needs
vi application.yml
# run
java -jar kafka-map.jar 

Running in System service

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
EOF

Reload system service && set boot auto-start && start service && view status

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

Usage

Then use the browser to open the server's port 8080 to access.

FAQ

What if I don't want to use port 8080?

Add --server.port=1234 to the startup command to modify the port to 1234.

# example
java -jar kafka-map.jar --server.port=1234

About

一个美观简洁且强大的kafka web管理工具。 Gitee 只用于镜像,Issues 请移步 https://github.com/dushixiang/kafka-map expand collapse
Cancel

Releases (8)

All

kafka-map

Contributors

All

Activities

Load More
can not load any more
Java
1
https://gitee.com/dushixiang/kafka-map.git
git@gitee.com:dushixiang/kafka-map.git
dushixiang
kafka-map
kafka-map
master

Search