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
↓ 1 callers
Method
getResList
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/checker/zookeeper/HealthCheckZookeeperService.java:57
↓ 1 callers
Method
getResponseBodyAndIgnoreException
(ClientHttpResponse response)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:184
↓ 1 callers
Method
getRowById
(Long connectClusterId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:242
↓ 1 callers
Function
getRowDetailData
(topicName: string, key?: number)
km-console/packages/layout-clusters-fe/src/pages/Jobs/TeskDetails.tsx:27
↓ 1 callers
Function
getScopeList
()
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/index.tsx:152
↓ 1 callers
Function
getScopeList
()
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/SelectContent.tsx:160
↓ 1 callers
Function
getScopeList
()
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/index.tsx:170
↓ 1 callers
Method
getServerStartTime
(Long clusterPhyId, String jmxHost, Integer jmxPort, JmxConfig jmxConfig)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/jmx/JmxDAO.java:17
↓ 1 callers
Method
getSessionTimeoutUnitMs
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/config/ZKConfig.java:36
↓ 1 callers
Method
getShardId
private method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:71
↓ 1 callers
Function
getSourceKafkaClustersList
()
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:169
↓ 1 callers
Method
getSpecifiedTypeAclByZKClient
(Long clusterPhyId, PatternType patternType)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:225
↓ 1 callers
Method
getStartTimeAndBuildBroker
(Long clusterPhyId, Node newNode, JmxConfig jmxConfig)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:361
↓ 1 callers
Method
getStatus
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:26
↓ 1 callers
Method
getStatusBySubStatus
(int totalJobNum, int successJobNu,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:44
↓ 1 callers
Function
getStylesheetLink
(ident)
km-console/packages/layout-clusters-fe/config/registerApps.js:37
↓ 1 callers
Method
getSubJobPartitionDetail
获取 job 相关的子任务的 partition 流量信息 @param jobId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:80
↓ 1 callers
Method
getSubJobPartitionDetail
获取任务详细信息 @param job job @return AbstractTaskDetail
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:92
↓ 1 callers
Method
getSubJobsByJobId
获取迁移任务信息
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:52
↓ 1 callers
Function
getSupplementaryInterval
(range: number)
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:108
↓ 1 callers
Function
getSupportKafkaVersion
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/HomePage.tsx:142
↓ 1 callers
Function
getSupportKafkaVersion
()
km-console/packages/layout-clusters-fe/src/pages/SingleClusterDetail/LeftSider.tsx:28
↓ 1 callers
Function
getTableColumns
(props: any)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/config.tsx:365
↓ 1 callers
Function
getTableColumns
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/config.tsx:376
↓ 1 callers
Method
getTaskDetail
获取任务详细信息 @param job job @return AbstractTaskDetail
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:78
↓ 1 callers
Function
getTaskDetailsColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:245
↓ 1 callers
Method
getTaskModifyDetail
获取任务详细信息 @param job job @return AbstractTaskDetail
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:85
↓ 1 callers
Function
getTaskPlanData
(params: any)
km-console/packages/layout-clusters-fe/src/components/TopicJob/ReplicaMove.tsx:206
↓ 1 callers
Method
getTopNConnectClusterIds
(Long clusterPhyId, List<String> metricNameList,
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/cluster/ConnectClusterMetricESDAO.java:131
↓ 1 callers
Method
getTopNConnectors
(Long clusterPhyId, List<String> metricNam
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:177
↓ 1 callers
Method
getTopNTopics
(Long clusterPhyId, List<String> metricNameList,
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:316
↓ 1 callers
Function
getTopicACLsColmns
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/config.tsx:38
↓ 1 callers
Method
getTopicAclFromDB
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/KafkaAclService.java:18
↓ 1 callers
Method
getTopicBrokerAll
(Long clusterPhyId, String topicName, String searchBrokerHost)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/TopicStateManager.java:19
↓ 1 callers
Method
getTopicBrokerSingle
(Long clusterPhyId, String topicName,
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/TopicStateManagerImpl.java:345
↓ 1 callers
Method
getTopicBrokersPartitionsSummary
(Long clusterPhyId, String topicName)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/TopicStateManager.java:27
↓ 1 callers
Method
getTopicConfig
(Long clusterPhyId, String topicName)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncTopicConfigTask.java:70
↓ 1 callers
Method
getTopicConfigDetailFromKafka
从Kafka直接获取Topic配置 @param clusterPhyId 物理集群ID @param topicName Topic名称 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicConfigService.java:31
↓ 1 callers
Method
getTopicConfigDetailFromKafka
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicConfigServiceImpl.java:130
↓ 1 callers
Function
getTopicConfigurationColmns
(arg: any)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/config.tsx:135
↓ 1 callers
Method
getTopicExtend
(Long existPartitionNum, Long totalPartitionNum,String expandParam)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/MsgConstant.java:45
↓ 1 callers
Method
getTopicFromDB
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:310
↓ 1 callers
Function
getTopicGroupPartitionsHistory
(hashData: HashData)
km-console/packages/layout-clusters-fe/src/pages/Consumers/ConsumerGroupDetail.tsx:189
↓ 1 callers
Function
getTopicList
()
km-console/packages/layout-clusters-fe/src/components/TopicJob/TopicMirror.tsx:51
↓ 1 callers
Function
getTopicList
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/ClusterNorms.tsx:70
↓ 1 callers
Function
getTopicList
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:321
↓ 1 callers
Function
getTopicList
()
km-console/packages/layout-clusters-fe/src/pages/Connect/AddConnector.tsx:416
↓ 1 callers
Function
getTopicList
(givenSourceKafkaId: any)
km-console/packages/layout-clusters-fe/src/pages/MirrorMaker2/AddMM2.tsx:183
↓ 1 callers
Method
getTopicMessages
(Long clusterPhyId, String topicName, TopicRecordDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/TopicStateManager.java:21
↓ 1 callers
Function
getTopicMessagesColmns
()
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/config.tsx:73
↓ 1 callers
Function
getTopicMetaData
(newValue: any)
km-console/packages/layout-clusters-fe/src/pages/SecurityACLs/EditDrawer.tsx:91
↓ 1 callers
Method
getTopicMetadata
(Long clusterPhyId, String topicName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:94
↓ 1 callers
Method
getTopicPartitionMapFromKafka
(Long clusterPhyId, String topicName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:19
↓ 1 callers
Method
getTopicPartitions
(Long clusterPhyId, String topicName, List<String> metricsNames)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/TopicStateManager.java:25
↓ 1 callers
Method
getTopicSizeFromCacheFirst
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:34
↓ 1 callers
Method
getTopicsFromAdminClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:262
↓ 1 callers
Method
getTopicsFromZKClient
(ClusterPhy clusterPhy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java:284
↓ 1 callers
Function
getTopicsMetaData
(hashData: HashData)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/ConsumerGroupDetail.tsx:243
↓ 1 callers
Function
getTopicsMetaData
()
km-console/packages/layout-clusters-fe/src/pages/ConsumerGroup/ExpandedRow.tsx:206
↓ 1 callers
Method
getTopicsMirrorInfo
@param clusterPhyId @param topicName @return
km-enterprise/km-ha/src/main/java/com/xiaojukeji/know/streaming/km/ha/mirror/service/MirrorTopicService.java:29
↓ 1 callers
Function
getTranformedBytes
(bytes: number)
km-console/packages/layout-clusters-fe/src/pages/TopicDetail/BrokersDetail.tsx:71
↓ 1 callers
Method
getType
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobHandleEnum.java:25
↓ 1 callers
Method
getTypeByCode
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/group/GroupTypeEnum.java:34
↓ 1 callers
Method
getTypeByProtocolType
(String protocolType)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/group/GroupTypeEnum.java:44
↓ 1 callers
Method
getVersionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:63
↓ 1 callers
Method
getVersionItemType
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:69
↓ 1 callers
Function
getWorkersColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Connect/config.tsx:286
↓ 1 callers
Method
getZKClientCreateTime
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminZKClient.java:57
↓ 1 callers
Method
getZKUrl
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/kafka/KafkaTestContainer.java:28
↓ 1 callers
Method
getZeroDate
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:246
↓ 1 callers
Method
getZnode
(Long clusterPhyId, String path)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/ZnodeService.java:12
↓ 1 callers
Method
getZnodeVO
(Long clusterPhyId, String path)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/ClusterZookeepersManager.java:18
↓ 1 callers
Function
getZookeeperColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/config.tsx:42
↓ 1 callers
Method
globalConfig
()
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/DataSourceConfig.java:36
↓ 1 callers
Function
gm
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
go
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
gr
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Method
groupIdIsUnrepresentable
(String groupId)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1188
↓ 1 callers
Method
groupInstanceId
The instance id of the group member.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/kafka/KSMemberDescription.java:60
↓ 1 callers
Method
groupMetric2SinkPoint
(List<GroupMetrics> groupMetrics)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:140
↓ 1 callers
Function
gx
(t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
h
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:11
↓ 1 callers
Function
hG
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Method
handleChildChange
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/BrokersNodeChangeHandler.java:51
↓ 1 callers
Method
handleChildChange
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/TopicsNodeChangeHandler.java:51
↓ 1 callers
Method
handleChildChange
()
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ConfigNotificationNodeChangeHandler.java:52
↓ 1 callers
Method
handleConnectClusterMetadata
(Long clusterPhyId, String groupName, KSGroupDescription ksGroupDescription)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/metadata/SyncConnectClusterAndWorkerTask.java:135
↓ 1 callers
Method
handleErrorResponse
(String indexName, List<? extends BaseESPO> pos, ESBatchResponse response)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:460
↓ 1 callers
Method
handleEvent
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/schedule/ScheduleFlushConnectClusterTask.java:94
↓ 1 callers
Method
handleEvent
()
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/schedule/ScheduleFlushClusterTask.java:96
↓ 1 callers
Method
handleGroupMetricESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/GroupMetricESDAO.java:167
↓ 1 callers
Method
handleGroupMetrics
(ESQueryResponse response, String aggType, List<String> metrics)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/GroupMetricESDAO.java:193
↓ 1 callers
Method
handleListESQueryResponse
(ESQueryResponse response, List<String> metrics, String aggType)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/TopicMetricESDAO.java:376
↓ 1 callers
Method
handleListESQueryResponse
(ESQueryResponse response, List<String> metricNameList, String aggType)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/ClusterMetricESDAO.java:191
↓ 1 callers
Method
handleListESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/ZookeeperMetricESDAO.java:70
↓ 1 callers
Method
handleListESQueryResponse
(ESQueryResponse response, List<String> metricNameList, String aggType)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java:219
↓ 1 callers
Method
handleListESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:214
↓ 1 callers
Method
handleListESQueryResponse
private method
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/cluster/ConnectClusterMetricESDAO.java:166
↓ 1 callers
Method
handleResponse
Process the call response. @param abstractResponse The AbstractResponse.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:595
↓ 1 callers
Method
handleResponses
Handle responses from the server. @param now The current time in milliseconds. @param responses The latest responses fr
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:907
← previous
next →
3,701–3,800 of 6,956, ranked by callers