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
| 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:latestdownload
wget https://github.com/dushixiang/kafka-map/releases/latest/download/kafka-map.tgzunzip
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
EOFReload system service && set boot auto-start && start service && view status
systemctl daemon-reload
systemctl enable kafka-map
systemctl start kafka-map
systemctl status kafka-mapThen use the browser to open the server's port 8080 to access.
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
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent