From c23870e020350c9d3266a9002683ab89d96c830a Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao@didiglobal.com>
Date: Thu, 17 Sep 2020 19:04:33 +0800
Subject: [PATCH] bugfix, fix topic overview page

---
 .../manager/service/service/impl/TopicServiceImpl.java      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicServiceImpl.java b/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicServiceImpl.java
index 0bbc6f55..0a5de14b 100644
--- a/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicServiceImpl.java
+++ b/service/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicServiceImpl.java
@@ -343,9 +343,9 @@ public class TopicServiceImpl implements TopicService {
             topicOverviewDTO.setBytesInPerSec(topicMetrics.getBytesInPerSec());
             topicOverviewDTO.setProduceRequestPerSec(topicMetrics.getTotalProduceRequestsPerSec());
         } else {
-//            topicMetrics = jmxService.getSpecifiedTopicMetricsFromJmx(clusterId, topicName, TopicMetrics.getFieldNameList(MetricsType.TOPIC_FLOW_DETAIL), true);
-            topicOverviewDTO.setBytesInPerSec(0.0);
-            topicOverviewDTO.setProduceRequestPerSec(0.0);
+            topicMetrics = jmxService.getSpecifiedTopicMetricsFromJmx(clusterId, topicName, TopicMetrics.getFieldNameList(MetricsType.TOPIC_FLOW_DETAIL), true);
+            topicOverviewDTO.setBytesInPerSec(topicMetrics.getBytesInPerSec());
+            topicOverviewDTO.setProduceRequestPerSec(topicMetrics.getBytesOutPerSec());
         }
         return topicOverviewDTO;
     }