# Kafka-King

**Repository Path**: mxm2005/Kafka-King

## Basic Information

- **Project Name**: Kafka-King
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2025-09-17
- **Last Updated**: 2025-09-17

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

<h1 align="center">Kafka King </h1>

![](docs/snap/p0.png)

<h4 align="center"><strong>简体中文</strong> | <a href="https://github.com/Bronya0/Kafka-King/blob/main/docs/README_EN.md">English</a></h4>

<div align="center">

![License](https://img.shields.io/github/license/Bronya0/Kafka-King)
![GitHub release](https://img.shields.io/github/release/Bronya0/Kafka-King)
![GitHub All Releases](https://img.shields.io/github/downloads/Bronya0/Kafka-King/total)
![GitHub stars](https://img.shields.io/github/stars/Bronya0/Kafka-King)
![GitHub forks](https://img.shields.io/github/forks/Bronya0/Kafka-King)

<strong>一个现代、实用的kafka GUI客户端。</strong>
</div>

本项目是一个kafka GUI客户端，支持各个系统，开源免费、简单好用。
点个star支持作者辛苦开源吧 谢谢❤❤

加群和作者一起交流： <a target="_blank" href="https://qm.qq.com/cgi-bin/qm/qr?k=pDqlVFyLMYEEw8DPJlRSBN27lF8qHV2v&jump_from=webapi&authKey=Wle/K0ARM1YQWlpn6vvfiZuMedy2tT9BI73mUvXVvCuktvi0fNfmNR19Jhyrf2Nz">研发技术交流群：964440643</a>
 
同款elasticsearch客户端 `ES-King` ：https://github.com/Bronya0/ES-King 


# Kafka-King功能清单
- [x] 查看集群节点列表（完成）
- [x] 支持PLAIN、SSL、SASL（完成）
- [x] 创建（支持批量）、删除主题，指定副本数、分区数（完成）
- [x] 支持根据消费者组统计每个topic的消息总量、提交总量、积压量（完成）
- [x] 支持查看topic的分区的详细信息（offset），并支持添加额外的分区（完成）
- [x] 支持模拟生产者，批量发送消息，是否开启gzip压缩、acks、batch_size、liner_ms，及headers，可以用来做性能调优（完成）
- [x] 支持模拟消费者，按照内置的组进行指定size的消费（完成）
- [x] 支持图表监控多个topic的消息生产性能、消费性能、积压情况（完成）
- [x] 健康检查（完成）
- [x] 多彩主题（完成）
- [x] 支持查看消费者组、消费者及订阅的topic、分区（完成）
- ……

# 下载
[下载地址](https://github.com/Bronya0/Kafka-King/releases)，点击【Assets】，选择自己的平台下载，支持windows、macos、linux。

> 小提示：使用前请检查kafka集群配置的`advertised.listeners`，如果配置是域名，那么在King中填写连接地址时，请提前在本机电脑的hosts文件中添加对应域名解析，否则会因为无法解析域名而报NodeNotReadyError

> ubuntu桌面用户请安装涉及依赖：sudo apt install libmpv1
# 功能截图

读取生产性能、消费性能、积压情况
![](docs/snap/p11.png)



添加kafka连接，支持ssl、sasl、kerberos认证

kafka api 版本不写会自动推测(明确知道的建议填写)
![](docs/snap/p0.png)


## 操作topic
主题列表，支持删除主题

支持根据消费者组统计每个topic的消息积压量（选择某个消费组，点击刷新按钮即可。）

![](docs/snap/p9.png)

创建主题（支持批量）

![](docs/snap/p4.png)

## 查看topic的详细配置
![](docs/snap/p6.png)

## 自动获取集群broker列表
![](docs/snap/p2.png)

## 模拟生产者消费者
- 支持模拟生产者，批量发送消息，是否开启gzip压缩
- 支持模拟消费者，按照内置的组进行指定size的消费

![](docs/snap/p8.png)
![](docs/snap/p10.png)



## 分区操作
- 支持查看topic的分区的详细信息
- 支持为主题添加额外的分区
- 支持查看每个分区的消息offset

![](docs/snap/p5.png)


## 消费者组操作
支持查看消费者组、消费者及订阅的topic、分区


# 快速开始
在右侧release下的Assets选择对应版本下载即可。
或者点击 https://github.com/Bronya0/Kafka-King/releases

# 构建
只有要研究源码才需要手动构建

pip install -r requirements.txt

flet pack main.py -i assets/icon.ico  -n kafka-king --add-data=assets/*:assets --product-name kafka-king

## QQ交流群
<a target="_blank" href="https://qm.qq.com/cgi-bin/qm/qr?k=pDqlVFyLMYEEw8DPJlRSBN27lF8qHV2v&jump_from=webapi&authKey=Wle/K0ARM1YQWlpn6vvfiZuMedy2tT9BI73mUvXVvCuktvi0fNfmNR19Jhyrf2Nz">KingTool研发技术交流群：964440643</a>

![](assets/qq.jpg)


# Star星星
[![Stargazers over time](https://starchart.cc/Bronya0/Kafka-King.svg)](https://starchart.cc/Bronya0/Kafka-King)


# License
Apache-2.0 license

# 感谢
- flet-dev：https://github.com/flet-dev/flet
- kafka-python：https://github.com/dpkp/kafka-python