MCPcopy
hub / github.com/didi/KnowStreaming

github.com/didi/KnowStreaming @v3.4.0 sqlite

repository ↗ · DeepWiki ↗ · release v3.4.0 ↗
8,026 symbols 27,603 edges 1,149 files 984 documented · 12%
README

<a href="https://knowstreaming.com">产品官网</a> | 
<a href="https://github.com/didi/KnowStreaming/releases">下载地址</a> | 
<a href="https://doc.knowstreaming.com/product">文档资源</a> | 
<a href="https://demo.knowstreaming.com">体验环境</a>

LastCommit

License

License

Issues

Slack


Know Streaming 简介

Know Streaming是一套云原生的Kafka管控平台,脱胎于众多互联网内部多年的Kafka运营实践经验,专注于Kafka运维管控、监控告警、资源治理、多活容灾等核心场景。在用户体验、监控、运维管控上进行了平台化、可视化、智能化的建设,提供一系列特色的功能,极大地方便了用户和运维人员的日常使用,让普通运维人员都能成为Kafka专家。

我们现在正在收集 Know Streaming 用户信息,以帮助我们进一步改进 Know Streaming。 请在 issue#663 上提供您的使用信息来支持我们:谁在使用 Know Streaming

整体具有以下特点:

  • 👀  零侵入、全覆盖
  • 无需侵入改造 Apache Kafka ,一键便能纳管 0.10.x ~ 3.x.x 众多版本的Kafka,包括 ZKRaft 运行模式的版本,同时在兼容架构上具备良好的扩展性,帮助您提升集群管理水平;

  • 🌪️  零成本、界面化

  • 提炼高频 CLI 能力,设计合理的产品路径,提供清新美观的 GUI 界面,支持 Cluster、Broker、Zookeeper、Topic、ConsumerGroup、Message、ACL、Connect 等组件 GUI 管理,普通用户5分钟即可上手;

  • 👏  云原生、插件化

  • 基于云原生构建,具备水平扩展能力,只需要增加节点即可获取更强的采集及对外服务能力,提供众多可热插拔的企业级特性,覆盖可观测性生态整合、资源治理、多活容灾等核心场景;

  • 🚀  专业能力

  • 集群管理:支持一键纳管,健康分析、核心组件观测 等功能;
  • 观测提升:多维度指标观测大盘、观测指标最佳实践 等功能;
  • 异常巡检:集群多维度健康巡检、集群多维度健康分 等功能;
  • 能力增强:集群负载均衡、Topic扩缩副本、Topic副本迁移 等功能;

  产品图

文档资源

开发相关手册

产品相关手册

点击 这里,也可以从官网获取到更多文档

产品网址 - 产品官网:https://knowstreaming.com - 体验环境:https://demo.knowstreaming.com,登陆账号:admin/admin

成为社区贡献者

  1. 贡献源码 了解如何成为 Know Streaming 的贡献者
  2. 具体贡献流程
  3. 开源激励计划
  4. 贡献者名单

获取KnowStreaming开源社区证书。

加入技术交流群

1、知识星球

👍 我们正在组建国内最大,最权威的 Kafka中文社区

在这里你可以结交各大互联网的 Kafka大佬 以及 4000+ Kafka爱好者,一起实现知识共享,实时掌控最新行业资讯,期待 👏   您的加入中~ https://z.didi.cn/5gSF9

有问必答~! 互动有礼~!

PS: 提问请尽量把问题一次性描述清楚,并告知环境信息情况~!如使用版本、操作步骤、报错/警告信息等,方便大V们快速解答~

 

2、微信群

微信加群:添加PenceXieszzdzhp001的微信号备注KnowStreaming加群。

加群之前有劳点一下 star,一个小小的 star 是对KnowStreaming作者们努力建设社区的动力。

感谢感谢!!!

wx

Star History

Star History Chart

Extension points exported contracts — how you extend this code

ConnectClusterMetricService (Interface)
@author didi [3 implementers]
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterMetricService.java
KafkaClient (Interface)
(no doc) [5 implementers]
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaClient.java
FourLetterWordDataParser (Interface)
四字命令结果解析类 [3 implementers]
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/FourLetterWordDataParser.java
WorkerConnectorManager (Interface)
@author wyb @date 2022/11/14 [3 implementers]
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/WorkerConnectorManager.java
TrickJumpLoginService (Interface)
@author zengqiao @date 21/5/18 [2 implementers]
km-extends/km-account/src/main/java/com/xiaojukeji/know/streaming/km/account/login/trick/TrickJumpLoginService.java
MirrorTopicService (Interface)
(no doc) [3 implementers]
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/MirrorTopicService.java
ILocaleMap (Interface)
(no doc)
km-console/packages/config-manager-fe/src/app.tsx
MetaDataService (Interface)
Kafka元信息服务接口 [3 implementers]
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/meta/MetaDataService.java

Core symbols most depended-on inside this repo

add
called by 908
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/ZKWatcherManager.java
call
called by 695
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java
getData
called by 491
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/KafkaZKDAO.java
apply
called by 423
km-console/packages/layout-clusters-fe/config/CoverHtmlWebpackPlugin.js
buildSuc
called by 418
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java
getId
called by 331
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/EntityIdInterface.java
name
called by 263
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java
buildFromRSAndMsg
called by 259
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/Result.java

Shape

Function 4,141
Method 2,815
Class 783
Interface 233
Enum 54

Languages

TypeScript53%
Java46%
Python1%

Modules by API surface

km-console/packages/layout-clusters-fe/static/js/echarts.min.js1,270 symbols
km-console/packages/layout-clusters-fe/static/js/antd.min.js760 symbols
km-console/packages/layout-clusters-fe/static/js/lodash.min.js473 symbols
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js320 symbols
km-console/packages/layout-clusters-fe/static/js/moment.min.js115 symbols
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js96 symbols
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java79 symbols
km-dist/helm/charts/elasticsearch/tests/elasticsearch_test.py73 symbols
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js55 symbols
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java42 symbols
km-console/packages/layout-clusters-fe/static/js/react-router.min.js41 symbols
km-console/packages/layout-clusters-fe/static/js/react.production.min.js35 symbols

Dependencies from manifests, versioned

com.alibaba:fastjson
com.baomidou:mybatis-plus-boot-starter
com.github.oshi:oshi-core5.6.1 · 1×
com.google.code.findbugs:jsr3053.0.2 · 1×
com.google.guava:guava25.0-jre · 1×
com.xiaojukeji.kafka:km-account
com.xiaojukeji.kafka:km-biz
com.xiaojukeji.kafka:km-collector
com.xiaojukeji.kafka:km-common
com.xiaojukeji.kafka:km-core

Datastores touched

(mysql)Database · 1 repos

For agents

$ claude mcp add KnowStreaming \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact