Commit a96f10e
File tree
2,443 files changed
+93472
-127443
lines changed- bin
- container
- dockerfiles
- docker-depends
- mysql
- helm
- charts
- templates
- tests
- distribution
- bin
- conf
- docs
- assets
- images/common
- readme
- dev_guide
- assets
- dynamic_config_manager
- increase_the_indicators_reported_to_monitor_system
- kcm
- monitor_system_integrate_with_self
- multi_version_compatible
- startup_using_source_code
- drawio
- install_guide
- user_guide
- add_cluster
- assets
- assets
- faq
- resource_apply
- kafka-manager-common
- src
- main/java/com/xiaojukeji/kafka/manager/common
- annotations
- bizenum
- gateway
- constant
- entity
- ao
- account
- analysis
- api
- cluster
- config
- expert
- consumer
- expert
- gateway
- reassign
- remote
- topic
- dto
- config
- gateway
- normal
- op
- reassign
- topic
- rd
- metrics
- pojo
- gateway
- vo
- common
- gateway
- normal
- app
- cluster
- consumer
- order
- detail
- topic
- op
- expert
- reassign
- task
- rd
- broker
- cluster
- events
- metrics
- exception
- utils
- factory
- jmx
- zookeeper
- znode
- brokers
- config
- didi
- test/java/com/xiaojukeji/kafka/manager/common/utils
- kafka-manager-console
- src
- assets/image
- component
- antd
- chart
- clipboard
- editor
- expand-card
- flow-table
- x-form-wrapper
- x-form
- constants
- container
- admin
- bill-management
- broker-detail
- cluster-detail
- cluster-list
- data-curve
- operation-detail
- operation-management
- operation-record
- alarm
- add-alarm
- alarm-detail
- app
- cluster
- cluster-detail
- common-curve
- drawer
- error
- expert
- diagnosis
- topic-governance
- topic-hotspot
- topic-partition
- full-screen
- header
- modal
- admin
- topic
- topic-detail
- user-center
- wrapper
- lib
- routers
- page
- login
- store
- styles
- types
- kafka-manager-core
- src
- main/java/com/xiaojukeji/kafka/manager/service
- cache
- service
- gateway
- impl
- impl
- strategy
- healthscore
- quota
- utils
- zookeeper
- test
- java
- META-INF
- com/xiaojukeji/kafka/manager/service
- config
- service
- gateway
- strategy
- utils
- resources
- kafka-manager-dao
- src/main
- java/com/xiaojukeji/kafka/manager
- dao
- gateway
- impl
- impl
- task
- vfs
- resources
- mapper
- kafka-manager-extends
- kafka-manager-account
- src
- main/java/com/xiaojukeji/kafka/manager/account
- common
- component
- account
- ldap
- login/trick
- sso
- impl
- test
- java/com/xiaojukeji/kafka/manager/account
- config
- resources
- distribution
- kafka-manager-bpm
- src
- main/java/com/xiaojukeji/kafka/manager/bpm
- common
- entry
- apply
- gateway
- detail
- handle
- component
- impl
- order
- impl
- gateway
- test
- java/com/xiaojukeji/kafka/manager/bpm
- config
- order
- resources
- distribution
- kafka-manager-kcm
- src
- main
- java/com/xiaojukeji/kafka/manager/kcm
- common
- bizenum
- entry
- ao
- dto
- component
- agent
- n9e
- entry
- bizenum
- storage
- common
- s3
- impl
- tasks
- resources
- test
- java/com/xiaojukeji/kafka/manager/kcm
- config
- resources
- distribution
- kafka-manager-monitor
- src
- main/java/com/xiaojukeji/kafka/manager/monitor
- common
- entry
- bizenum
- dto
- sink
- vo
- monitor
- utils
- component
- n9e
- entry
- bizenum
- impl
- test
- java/com/xiaojukeji/kafka/manager/monitor
- config
- resources
- distribution
- kafka-manager-notify
- src/main/java/com/xiaojukeji/kafka/manager/notify
- common
- notifyer
- kafka-manager-openapi
- src
- main/java/com/xiaojukeji/kafka/manager/openapi
- common
- constant
- dto
- vo
- impl
- test
- java/com/xiaojukeji/kafka/manager/openapi
- config
- resources
- distribution
- kafka-manager-task
- src/main/java/com/xiaojukeji/kafka/manager/task
- common
- component
- config
- dispatch
- biz
- metrics
- collect
- delete
- store
- op
- listener
- biz
- sink
- db
- kafka
- monitor
- schedule
- metadata
- kafka-manager-web
- src
- main
- java/com/xiaojukeji/kafka/manager/web
- api
- versionone
- gateway
- normal
- op
- rd
- thirdpart
- config
- converters
- inteceptor
- metrics
- utils
- resources
- distribution
- test
- java/com/xiaojukeji/kafka/manager/web
- api/versionone
- gateway
- normal
- op
- rd
- thirdpart
- config
- resources
- km-biz
- src/main/java/com/xiaojukeji/know/streaming/km/biz
- broker
- impl
- cluster
- impl
- group
- impl
- kafkaacl
- impl
- kafkauser
- impl
- reassign
- impl
- self
- impl
- topic
- impl
- version
- impl
- km-collector
- src/main/java/com/xiaojukeji/know/streaming/km/collector
- metric
- service
- km-common
- src/main/java/com/xiaojukeji/know/streaming/km/common
- annotations
- enterprise
- bean
- dto
- acl
- cluster
- config
- platform
- group
- job
- kafkauser
- metrices
- oprecord
- pagination
- field
- partition
- reassign
- change
- move
- plan
- topic
- util
- entity
- assign
- broker
- cluster
- common
- config
- healthcheck
- kafkaconfig
- metric
- group
- health
- job
- content
- detail
- kafkacontroller
- kafkauser
- metrics
- pagination
- param
- acl
- broker
- cluster
- config
- group
- kafkauser
- metric
- partition
- reassign
- topic
- partition
- reassign
- job
- detail
- strategy
- record
- result
- search
- topic
- util
- version
- event
- cluster
- kafka/zk
- metric
- po
- broker
- changerecord
- cluster
- config
- group
- health
- job
- kafkacontrollr
- km
- metrice
- partition
- reassign
- topic
- vo
- acl
- broker
- changerecord
- cluster
- res
- config
- kafka
- metric
- platform
- group
- health
- job
- sub
- kafkacontroller
- kafkauser
- log
- metadata
- metrics
- line
- point
- reassign
- job
- plan
- self
- topic
- broker
- partition
- util
- version
- component
- constant
- kafka
- converter
- enums
- cluster
- config
- group
- health
- job
- metric
- operaterecord
- topic
- valid
- version
- exception
- jmx
- utils
- kafka
- zookeeper/znode
- brokers
- config
- km-console
- packages
- config-manager-fe
- config
- src
- @types
- api
- components
- CardBar
- TagsWithHide
- TypicalListCard
- constants
- locales
- pages
- ConfigManage
- OperationLog
- UserManage
- layout-clusters-fe
- config
- src
- @types
- api
- assets
- components
- CardBar
- CodeMirrorFormItem
- DDSearchInput
- style
- DashboardDragChart
- DragGroup
- SingleChartHeader
- image
- style
- SmallChart
- SwitchTab
- TagsWithHide
- TopicJob
- TourGuide
- constants
- locales
- pages
- BrokerControllerChangeLog
- BrokerDashboard
- BrokerDetail
- BrokerList
- Consumers
- GroupList
- Jobs
- LoadRebalance
- style
- Login
- img
- MutliClusterPage
- NoLicense
- SecurityACLs
- SecurityUsers
- SingleClusterDetail
- DetailChart
- TestingConsumer
- component
- style
- TestingProduce
- component
- style
- TopicDashboard
- TopicDetail
- TopicList
- static/js
- tool
- km-core
- src
- main/java/com/xiaojukeji/know/streaming/km/core
- cache
- flusher
- zk
- handler
- service
- acl
- impl
- broker
- impl
- change/record
- impl
- cluster
- impl
- config
- impl
- group
- impl
- health
- checker
- broker
- cluster
- group
- topic
- checkresult
- impl
- score
- impl
- job
- handler
- impl
- kafkacontroller
- impl
- kafkauser
- impl
- km
- impl
- oprecord
- impl
- partition
- impl
- reassign
- impl
- replica
- impl
- topic
- impl
- version
- fe
- impl
- metrics
- test/java/META-INF
- km-dist
- helm
- charts
- elasticsearch
- examples
- config
- test
- default
- test
- docker-for-mac
- kubernetes-kind
- microk8s
- migration
- minikube
- multi
- test
- networkpolicy
- openshift
- test
- security
- test
- upgrade
- test
- templates
- test
- tests
- knowstreaming-web
- templates
- tests
- ksmysql
- templates
- templates
- tests
- init
- sql
- template
- km-extends
- km-account
- src/main/java/com/xiaojukeji/know/streaming/km/account
- common
- bizenum
- constant
- ldap
- exception
- login
- ldap
- remote
- trick
- impl
- km-monitor
- src/main/java/com/xiaojukeji/know/streaming/km/monitor
- common
- component
- prometheus
- km-persistence
- src/main
- java/com/xiaojukeji/know/streaming/km/persistence
- cache
- es
- dao
- dsls
- jmx
- impl
- kafka
- mysql
- broker
- changerecord
- cluster
- config
- group
- health
- job
- kafkacontroller
- km
- partition
- reassign
- topic
- schedule
- zk
- impl
- resources
- dsl
- BaseMetricESDAO
- BrokerMetricESDAO
- ClusterMetricESDAO
- GroupMetricESDAO
- PartitionMetricESDAO
- ReplicationMetricESDAO
- TopicMetricESDAO
- mybatis
- km-rest
- src
- main
- java/com/xiaojukeji/know/streaming/km/rest
- api/v3
- acl
- broker
- changerecord
- cluster
- config
- group
- health
- job
- kafkacontroller
- kafkauser
- open
- reassign
- replica
- self
- topic
- util
- version
- config
- handler
- interceptor
- resources
- distribution
- test/java/com/xiaojukeji/know/streaming/km
- core
- persistence/es
- km-task
- src/main/java/com/xiaojukeji/know/streaming/km/task
- client
- health
- job
- metadata
- metrics
- service
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,443 files changed
+93472
-127443
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | | - | |
8 | | - | |
9 | | - | |
10 | | - | |
11 | | - | |
12 | | - | |
13 | | - | |
14 | | - | |
15 | | - | |
16 | | - | |
17 | | - | |
18 | | - | |
19 | | - | |
20 | | - | |
21 | | - | |
22 | | - | |
23 | | - | |
24 | | - | |
25 | | - | |
26 | | - | |
27 | | - | |
28 | | - | |
29 | | - | |
30 | | - | |
31 | | - | |
32 | | - | |
33 | | - | |
34 | | - | |
35 | | - | |
36 | | - | |
37 | | - | |
38 | | - | |
39 | | - | |
40 | | - | |
41 | | - | |
42 | | - | |
43 | | - | |
44 | | - | |
45 | | - | |
46 | | - | |
47 | | - | |
48 | | - | |
49 | | - | |
50 | | - | |
51 | | - | |
52 | | - | |
53 | | - | |
54 | | - | |
55 | | - | |
56 | | - | |
57 | | - | |
58 | | - | |
59 | | - | |
60 | | - | |
61 | | - | |
62 | | - | |
63 | | - | |
64 | | - | |
65 | | - | |
66 | | - | |
67 | | - | |
68 | | - | |
69 | | - | |
70 | | - | |
71 | | - | |
72 | | - | |
73 | | - | |
74 | | - | |
75 | | - | |
76 | | - | |
77 | | - | |
78 | | - | |
79 | | - | |
80 | | - | |
81 | | - | |
82 | | - | |
83 | | - | |
84 | | - | |
85 | | - | |
86 | | - | |
87 | | - | |
88 | | - | |
89 | | - | |
90 | | - | |
91 | | - | |
92 | | - | |
93 | | - | |
94 | | - | |
95 | | - | |
96 | | - | |
97 | | - | |
98 | | - | |
99 | | - | |
100 | | - | |
101 | | - | |
102 | | - | |
103 | | - | |
104 | | - | |
105 | | - | |
106 | | - | |
107 | | - | |
108 | | - | |
109 | | - | |
110 | | - | |
111 | | - | |
112 | | - | |
113 | | - | |
114 | | - | |
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
7 | 7 | | |
8 | 8 | | |
9 | 9 | | |
10 | | - | |
| 10 | + | |
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
| |||
This file was deleted.
0 commit comments