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
deleteGroupTopicPartitionOffsetByClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:224
Method
deleteInDB
(Long connectClusterId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:122
Method
deleteInDBByKafkaClusterId
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:237
Method
deleteInDBByKafkaClusterId
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:41
Method
deleteInDBByKafkaClusterId
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:116
Method
deleteInDBByKafkaClusterId
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperServiceImpl.java:104
Method
deleteJobById
(@PathVariable Long clusterPhyId, @PathVariable Long jobId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:51
Method
deleteKafkaAcl
(ACLAtomParam aclAtomParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:124
Method
deleteKafkaAcl
(@Validated @RequestBody AclAtomDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/acl/AclController.java:41
Method
deleteKafkaUser
(KafkaUserParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:137
Method
deleteKafkaUser
(@Validated @RequestBody ClusterKafkaUserDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/kafkauser/KafkaUserController.java:40
Method
deleteKafkaUserByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:522
Method
deleteKafkaUserByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:505
Method
deleteMM2
(@Validated @RequestBody MirrorMaker2DeleteDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerController.java:41
Method
deleteMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:154
Method
deleteObject
DEL请求 @param url 请求地址
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:222
Function
deleteOffset
(record: any)
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/Detail.tsx:116
Method
deletePartitionsIfNotIn
(Long clusterPhyId, Set<String> topicNameSet)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:347
Function
deleteTesk
()
km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:130
Function
deleteTesk
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:137
Function
deleteTesk
()
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/index.tsx:62
Method
deleteTopic
(TopicParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:141
Method
deleteTopicCombineRes
删除Topic
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/OpTopicManager.java:16
Method
deleteTopicCombineRes
(Long clusterPhyId, String topicName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/OpTopicManagerImpl.java:119
Method
deleteTopicInDB
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:183
Method
desc
(String desc)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:94
Method
describedGroups
Return a map from group id to futures which yield group descriptions.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSDescribeGroupsResult.java:19
Method
destroy
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/KMTestEnvService.java:60
Method
destroyObject
(final PooledObject<KafkaConsumer<String, String>> p)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/KafkaConsumerFactory.java:34
Function
df
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:85
Function
dimensionChange
(val: string[])
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:337
Method
directFlatObject
(JSONObject obj)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:285
Function
disabledDate
(current)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:260
Function
disabledDate
(current)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:224
Function
disabledDateTime
(current: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:271
Function
disabledDateTime
(current: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaChange.tsx:235
Function
dj
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:42
Method
doHandler
(VersionItemTypeEnum typeEnum, String methodName, VersionItemParam param)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/impl/VersionControlServiceImpl.java:85
Method
doNothing
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/replica/impl/ReplicaMetricServiceImpl.java:113
Method
doNothing
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:313
Method
doNothing
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerMetricServiceImpl.java:474
Method
doNothing
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorMetricServiceImpl.java:208
Method
doNothing
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/mm2/impl/MirrorMakerMetricServiceImpl.java:201
Method
doNothing
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterMetricServiceImpl.java:143
Method
doNothing
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperMetricServiceImpl.java:277
Method
doNothing
doNothing
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:321
Method
doVCHandler
(Long clusterPhyId, String action, VersionItemParam param)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseKafkaVersionControlService.java:20
Method
doVCHandler
(Long connectClusterId, String action, VersionItemParam param)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/BaseConnectVersionControlService.java:22
Function
domElementGetter
()
km-console/packages/config-manager-fe/src/index.tsx:6
Method
double2Long
(Double d)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:369
Function
download
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:313
Function
dragCallback
(oldIndex: number, newIndex: number)
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/index.tsx:204
Function
dragEnd
({ oldIndex, newIndex }: { oldIndex: number; newIndex: number })
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/ChartList.tsx:33
Function
dragEnd
({ oldIndex, newIndex }: { oldIndex: number; newIndex: number })
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/DetailChart/index.tsx:220
Function
dragStart
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/ChartList.tsx:28
Function
dragStart
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/DetailChart/index.tsx:215
Function
drawerClose
(sure?: boolean)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/index.tsx:295
Function
dw
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
dx
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
e
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Function
eA
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
eC
()
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
eP
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
ea
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:100
Function
ea
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
ec
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:93
Function
editConnector
(detail: OperateInfo['detail'])
km-console/packages/layout-clusters-fe/src/pages/Connect/index.tsx:101
Function
editConnector
(detail: OperateInfo['detail'])
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/index.tsx:103
Function
editFlowLimit
()
km-console/packages/layout-clusters-fe/src/pages/Jobs/ViewJobsProgress.tsx:30
Function
editTableValidate
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceEditTable.tsx:75
Function
ef
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:82
Function
ei
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:174
Function
ek
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
ek
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
el
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:111
Function
ensureJQuerySupport
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Method
equalList
是空字符串
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ValidateUtils.java:75
Method
equals
(Object o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/Triple.java:43
Method
equals
(Object o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberDescription.java:33
Method
equals
(Object o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberConsumerAssignment.java:24
Function
er
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:26
Function
error
(content: ArgsProps)
km-console/packages/config-manager-fe/src/components/Notification/index.tsx:28
Function
error
(content: JointContent, duration?: ConfigDuration, onClose?: ConfigOnClose)
km-console/packages/config-manager-fe/src/components/Message/index.tsx:49
Function
error
(content: ArgsProps)
km-console/packages/layout-clusters-fe/src/components/Notification/index.tsx:28
Function
error
(content: JointContent, duration?: ConfigDuration, onClose?: ConfigOnClose)
km-console/packages/layout-clusters-fe/src/components/Message/index.tsx:49
Method
esRetryExecute
(String methodName, int tryCount, RetryExecutor.Handler handler)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpTimeoutRetry.java:27
Method
esRetryExecuteWithGivenTime
定制重试方法等待的时间 @param methodName 方法名称 @param tryCount 重试次数 @param handler 重试的操作 @param retrySleepTime 重试间隔的等待时间 @return 整个重试方法执行的结果 @throws ESOperateExce
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpTimeoutRetry.java:65
Function
et
(e,t)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
Function
eu
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Method
execute
(JobContext jobContext)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:65
Method
execute
(Long jobId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:261
Method
execute
重试操作，要么handler执行成功有返回值,要么报异常 @throws Exception 操作的异常
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java:81
Method
executePartitionReassignments
(ExecuteReassignParam executeReassignParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:147
Method
executeTaskByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:275
Method
executeTaskByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:256
Method
existConnectClusterDown
(Long kafkaClusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:222
Method
existServerDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:280
Method
existServerDown
存在服务挂掉 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/ZookeeperService.java:21
Method
existServerDown
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperServiceImpl.java:128
Method
expandTopic
扩分区
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/OpTopicService.java:24
← previous
next →
5,301–5,400 of 6,956, ranked by callers