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
collectPartitionMetricsFromKafka
(Long clusterPhyId, String topicName, Integer partitionId, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/PartitionMetricService.java:21
Method
collectPartitionMetricsFromKafka
(Long clusterPhyId, String topicName, Integer partitionId, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionMetricServiceImpl.java:125
Method
collectPartitionsMetricsFromKafkaWithCache
(Long clusterPhyId, String topicName, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionMetricServiceImpl.java:76
Method
collectTopicMetricsFromKafkaWithCacheFirst
(Long clusterPhyId, String topicName, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:104
Method
compareTo
(MetricPointVO o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/metrics/point/MetricPointVO.java:34
Method
compareTo
(MetricMultiValuePointVO o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/metrics/line/MetricMultiValuePointVO.java:30
Method
compareTo
(TopicAssignedCount o)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/assign/TopicAssignedCount.java:44
Method
compareTo
(ConnectCluster connectCluster)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/connect/ConnectCluster.java:74
Method
compareTo
(Delayed delayed)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/common/FutureTaskDelayQueueData.java:31
Method
configurer
register prometheus
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/KnowStreaming.java:40
Function
confirm
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ResetOffsetDrawer.tsx:80
Function
confirm
()
km-console/packages/layout-clusters-fe/src/pages/TopicList/ExpandPartition.tsx:21
Function
confirm
()
km-console/packages/layout-clusters-fe/src/pages/Consumers/ResetOffsetDrawer.tsx:82
Function
confirm
()
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/ResetOffsetDrawer.tsx:79
Method
constructUrlForConnection
(String queryString)
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:127
Method
constructor
(opts = {})
km-console/packages/layout-clusters-fe/config/CountComponentWebpackPlugin.js:6
Method
convert2GroupOverviewVO
(Group group)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/GroupConverter.java:26
Method
countAllBrokers
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:264
Method
countBrokerConfigDiffsFromDB
(Long clusterPhyId, List<String> excludeConfigs)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:112
Method
countByConnectClusterIdFromDB
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/ConnectorServiceImpl.java:127
Method
countJobsByCluster
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:333
Method
countJobsByClusterAndJobStatus
(Long clusterPhyId, Integer jobStatus)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:340
Method
countKafkaAclFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:132
Method
countKafkaUserAndDistinctFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:154
Method
countKafkaUserFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:58
Method
countKafkaUserFromDB
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:385
Method
countMetricValue
获取 match 命中或者不命中的次数，返回-1，代表查询异常
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/GroupMetricESDAO.java:94
Method
countMetricValueOccurrencesFromES
(Long clusterPhyId, String groupName, SearchTerm
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupMetricServiceImpl.java:171
Method
countMetricValueOccurrencesFromES
统计一段时间内，某个指标出现某个值的次数 @param clusterPhyId 集群ID @param topicName 消费组名称 @param searchMatch 指标 @param startTime 起始时间 @param endTime 结束时间 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicMetricService.java:132
Method
countMetricValueOccurrencesFromES
(Long clusterPhyId, String topicName, SearchTerm
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:290
Method
countMetricValueOccurrencesTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/TopicMetricESDAOTest.java:130
Method
countMetricValueTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/GroupMetricESDAOTest.java:61
Method
countResTypeAndDistinctFromDB
(Long clusterPhyId, ResourceType resourceType)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:139
Function
cr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:27
Method
create
(Long jobId, ReplaceReassignJob replaceReassignJob, String creator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:93
Method
create
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/KafkaConsumerFactory.java:24
Method
create
(long now)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:628
Method
createAclByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:204
Method
createAclByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:200
Method
createByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:296
Method
createByZKClientV1
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:338
Method
createByZKClientV2
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:317
Method
createConfigChangeNotificationVersionOne
(Long clusterPhyId, String entityType, String entityName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:235
Method
createConnector
(Long connectClusterId, String connectorName, Properties configs, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/OpConnectorService.java:13
Method
createConnector
(Long connectClusterId, String connectorName, Properties configs, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:67
Method
createConnector
(@Validated @RequestBody ConnectorCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectorController.java:43
Method
createConnector
(ConnectorCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/connector/impl/ConnectorManagerImpl.java:54
Method
createJob
(@PathVariable Long clusterPhyId, @RequestBody JobDTO jobDTO)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/job/KSJobController.java:44
Method
createKafkaAcl
(ACLAtomParam aclAtomParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:80
Method
createKafkaAcl
(@Validated @RequestBody List<AclAtomDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/acl/AclController.java:34
Method
createKafkaUser
(KafkaUserReplaceParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:97
Method
createKafkaUser
(@Validated @RequestBody ClusterKafkaUserTokenDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/kafkauser/KafkaUserController.java:33
Method
createKafkaUserWithTokenEncrypted
(ClusterKafkaUserTokenDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/kafkauser/impl/KafkaUserManagerImpl.java:29
Method
createMM2
(@Validated @RequestBody MirrorMakerCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/mm2/KafkaMirrorMakerController.java:34
Method
createMirrorMaker
(MirrorMakerCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:95
Method
createReassignmentPlanJson
(List<CreateMoveReplicaPlanDTO> dtoList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/impl/ReassignManagerImpl.java:46
Method
createReplicaChangePlanJson
(List<CreateChangeReplicasPlanDTO> dtoList)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/impl/ReassignManagerImpl.java:73
Method
createReplicasChangePlanJson
获取迁移计划
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/reassign/CommunityReassignController.java:36
Method
createReplicasMovePlanJson
(@RequestBody @Valid List<CreateMoveReplicaPlanDTO> dtoList)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/reassign/CommunityReassignController.java:43
Method
createRequest
(int timeoutMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1159
Method
createRequest
(int timeoutMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1260
Method
createRestApi
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/WebConfig.java:62
Method
createTopic
创建Topic
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/OpTopicService.java:14
Method
createTopic
(TopicCreateParam createParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:102
Method
createTopic
(@Validated @RequestBody TopicCreateDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicController.java:43
Method
createTopic
(TopicCreateDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/OpTopicManagerImpl.java:64
Function
cu
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:45
Function
cu
(r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
customCancel
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:55
Function
customSure
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:50
Function
cx
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function
d
()
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
Function
da
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:102
Method
dataSource
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/DataSourceConfig.java:29
Method
date2Long
(Date time, String formatStr)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:27
Method
date2Str
(Date date, String newFormatStr)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:204
Method
date2int
(Date time)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:161
Function
de
()
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
Function
decode
(e)
km-console/packages/layout-clusters-fe/static/js/fetch-polyfill.min.js:1
Method
delExpireIndex
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java:82
Method
delete
(Long jobId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:129
Method
delete
(Job job, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:52
Method
deleteAclByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:236
Method
deleteAclByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:231
Method
deleteById
(Long clusterPhyId, Long jobId, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:101
Method
deleteByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:264
Method
deleteByUpdateTimeBeforeInDB
(Long clusterPhyId, Date beforeTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:135
Method
deleteByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:280
Method
deleteClusterPhy
(@RequestParam("clusterPhyId") Long clusterPhyId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterPhyController.java:44
Method
deleteConnectCluster
(@RequestParam("connectClusterId") Long connectClusterId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectClusterController.java:29
Method
deleteConnector
(Long connectClusterId, String connectorName, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/connector/impl/OpConnectorServiceImpl.java:217
Method
deleteConnectors
(@Validated @RequestBody ConnectorDeleteDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/connect/KafkaConnectorController.java:54
Method
deleteForObject
GET请求 @param url 请求地址 @param headers 请求头 @param resultType 返回类型 @param <T> 泛型T @return T
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTool.java:346
Method
deleteGroupOffset
(DeleteGroupParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:75
Method
deleteGroupOffsetByClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:163
Method
deleteGroupOffsets
(@Validated @RequestBody GroupOffsetDeleteDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/group/GroupController.java:43
Method
deleteGroupOffsets
(GroupOffsetDeleteDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java:284
Method
deleteGroupTopicOffset
(DeleteGroupTopicParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:105
Method
deleteGroupTopicOffsetByClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:186
Method
deleteGroupTopicPartitionOffset
(DeleteGroupTopicPartitionParam param, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/OpGroupServiceImpl.java:135
← previous
next →
5,201–5,300 of 6,956, ranked by callers