Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/didi/KnowStreaming
/ functions
Functions
6,956 in github.com/didi/KnowStreaming
⨍
Functions
6,956
◇
Types & classes
1,070
Method
handleFailure
(Throwable throwable)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1280
Function
handleMenuClick
(e: string)
km-console/packages/layout-clusters-fe/src/pages/Login/index.tsx:41
Method
handleNullPointerException
(Exception e)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/handler/CustomGlobalExceptionHandler.java:34
Method
handleResponse
(AbstractResponse abstractResponse)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1169
Method
handleResponse
(AbstractResponse abstractResponse)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1268
Function
handleSubmit
({ userName, pw }: { userName: string; pw: string })
km-console/packages/layout-clusters-fe/src/pages/Login/login.tsx:43
Method
handleTopTopicESQueryResponse
(ESQueryResponse response, List<String> metricNameList, int topN)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:405
Method
handleZKClientNotExist
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/TopicsNodeWatcher.java:30
Method
handleZKClientNotExist
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/ControllerNodeWatcher.java:30
Method
handleZKClientNotExist
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/ConfigChangeNodeWatcher.java:26
Method
handleZKClientNotExist
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/BrokersNodeWatcher.java:29
Method
handler
(Handler handler)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java:67
Method
hasData
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/result/PaginationResult.java:105
Function
hasPermission
(permissionName: ConfigPermissionMap)
km-console/packages/config-manager-fe/src/pages/CommonConfig.tsx:50
Function
hasPermission
(permissionName: ClustersPermissionMap)
km-console/packages/layout-clusters-fe/src/pages/CommonConfig.tsx:115
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/Tuple.java:54
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/Triple.java:55
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/partition/PartitionPO.java:65
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/po/topic/TopicPO.java:84
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberDescription.java:45
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberConsumerAssignment.java:34
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSGroupDescription.java:59
Method
hashCode
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/metric/UserMetricConfig.java:32
Function
hb
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
hc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:94
Method
health
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/open/HealthController.java:22
Function
healthScoreCondition
()
km-console/packages/layout-clusters-fe/src/components/CardBar/const.ts:1
Function
hf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:84
Function
hf
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:172
Function
hg
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
hi
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:62
Function
hl
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
hm
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
hn
()
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Function
ho
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:76
Method
hostLegal
(String hostname)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/NetUtils.java:44
Function
hostSearch
(e: any)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:237
Function
hr
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:28
Function
hu
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
i
(e,t)
km-console/packages/layout-clusters-fe/static/js/single-spa-react.js:1
Function
i
(t)
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
Function
ia
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:100
Function
ia
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
ib
(f)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
ih
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:85
Function
index
()
km-console/packages/layout-clusters-fe/static/js/history.production.min.js:1
Method
index
写入单条
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:203
Method
indexExpMatch
(String index, String exp)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:87
Function
info
(content: ArgsProps)
km-console/packages/config-manager-fe/src/components/Notification/index.tsx:19
Function
info
(content: JointContent, duration?: ConfigDuration, onClose?: ConfigOnClose)
km-console/packages/config-manager-fe/src/components/Message/index.tsx:40
Function
info
(content: ArgsProps)
km-console/packages/layout-clusters-fe/src/components/Notification/index.tsx:19
Method
init
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:47
Method
init
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/TaskThreadPoolService.java:52
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/mm2/MirrorMakerMetricESSender.java:24
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/GroupMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/PartitionMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/ClusterMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/ZookeeperMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/BrokerMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/kafka/TopicMetricESSender.java:20
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/connect/ConnectClusterMetricESSender.java:24
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/sink/connect/ConnectorMetricESSender.java:24
Method
init
()
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:50
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/utils/ApiCallThreadPoolService.java:27
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:66
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:34
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:82
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/OpPartitionServiceImpl.java:55
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseMetricService.java:26
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectMetricService.java:15
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ZookeeperMetricVersionItems.java:58
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/GroupMetricVersionItems.java:32
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/BrokerMetricVersionItems.java:56
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ReplicaMetricVersionItems.java:34
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/TopicMetricVersionItems.java:49
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/PartitionMetricVersionItems.java:35
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java:131
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/ConnectClusterMetricVersionItems.java:52
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/ConnectorMetricVersionItems.java:124
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/connect/MirrorMakerMetricVersionItems.java:57
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java:54
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/impl/VersionControlServiceImpl.java:45
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:68
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:95
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:87
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:68
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:96
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:85
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/group/HealthCheckGroupService.java:39
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/topic/HealthCheckTopicService.java:45
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/broker/HealthCheckBrokerService.java:39
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectorService.java:51
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/HealthCheckConnectClusterService.java:45
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/connect/mm2/HealthCheckMirrorMakerService.java:70
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:47
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/cluster/HealthCheckClusterService.java:32
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:74
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:71
Method
init
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/DatabaseDataFlusher.java:58
Method
init
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/DataBaseDataLocalCache.java:45
← previous
next →
5,901–6,000 of 6,956, ranked by callers