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; }