Skip to content

Commit 95c9582

Browse files
author
zengqiao
committed
优化消费组详情指标为实时获取
1 parent a5fa9de commit 95c9582

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -272,15 +272,11 @@ private PaginationResult<GroupMetrics> pagingGroupTopicPartitionMetrics(Long clu
272272

273273

274274
// 获取Group指标信息
275-
Result<List<GroupMetrics>> groupMetricsResult = groupMetricService.listPartitionLatestMetricsFromES(
276-
clusterPhyId,
277-
groupName,
278-
topicName,
279-
latestMetricNames == null? Arrays.asList(): latestMetricNames
280-
);
275+
Result<List<GroupMetrics>> groupMetricsResult = groupMetricService.collectGroupMetricsFromKafka(clusterPhyId, groupName, latestMetricNames == null ? Arrays.asList() : latestMetricNames);
276+
281277

282278
// 转换Group指标
283-
List<GroupMetrics> esGroupMetricsList = groupMetricsResult.hasData()? groupMetricsResult.getData(): new ArrayList<>();
279+
List<GroupMetrics> esGroupMetricsList = groupMetricsResult.hasData() ? groupMetricsResult.getData().stream().filter(elem -> topicName.equals(elem.getTopic())).collect(Collectors.toList()) : new ArrayList<>();
284280
Map<Integer, GroupMetrics> esMetricsMap = new HashMap<>();
285281
for (GroupMetrics groupMetrics: esGroupMetricsList) {
286282
esMetricsMap.put(groupMetrics.getPartitionId(), groupMetrics);

0 commit comments

Comments
 (0)