"本项目 CDN 加速及安全防护由 Tencent EdgeOne 赞助：EdgeOne 提供长期有效的免费套餐，包含不限量的流量和请求，覆盖中国大陆节点，且无任何超额收费，感兴趣的朋友可以点击下面的链接领取"

亚洲最佳CDN、边缘和安全解决方案 - Tencent EdgeOne

亚太数据中心提供顶级的中国优化网络接入 · 低延时&高带宽&提供Tbps级本地清洗高防服务, 为您的业务保驾护航, 为您的客户提供极致体验.

加入社区 Telegram群组 https://t.me/SharonNetwork 可参与公益募捐或群内抽奖免费使用。

English | 简体中文

Add wings to programming and install navigation to kafka。

kafka-map is a kafka visualization tool developed using Java17 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).

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.

• Java17 or higher
• Apache Kafka 1.1.0 or higher

end

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

download

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

unzip

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

# kafka-map dir cd /usr/local/kafka-map # Modify the configuration according to your needs vi application.yml # run 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 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

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

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