bugfix, fix topic overview page

zengqiao · zengqiao · commit c23870e02035 · 2020-09-17T19:04:33.000+08:00
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
@@ -343,9 +343,9 @@ private TopicOverviewDTO getTopicOverviewDTO(Long clusterId, String topicName, I
             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;
     }

Original file line number	Diff line number	Diff line change
`@@ -343,9 +343,9 @@ private TopicOverviewDTO getTopicOverviewDTO(Long clusterId, String topicName, I`
`343`	`343`	`topicOverviewDTO.setBytesInPerSec(topicMetrics.getBytesInPerSec());`
`344`	`344`	`topicOverviewDTO.setProduceRequestPerSec(topicMetrics.getTotalProduceRequestsPerSec());`
`345`	`345`	`} else {`
`346`		`-// topicMetrics = jmxService.getSpecifiedTopicMetricsFromJmx(clusterId, topicName, TopicMetrics.getFieldNameList(MetricsType.TOPIC_FLOW_DETAIL), true);`
`347`		`- topicOverviewDTO.setBytesInPerSec(0.0);`
`348`		`- topicOverviewDTO.setProduceRequestPerSec(0.0);`
	`346`	`+ topicMetrics = jmxService.getSpecifiedTopicMetricsFromJmx(clusterId, topicName, TopicMetrics.getFieldNameList(MetricsType.TOPIC_FLOW_DETAIL), true);`
	`347`	`+ topicOverviewDTO.setBytesInPerSec(topicMetrics.getBytesInPerSec());`
	`348`	`+ topicOverviewDTO.setProduceRequestPerSec(topicMetrics.getBytesOutPerSec());`
`349`	`349`	`}`
`350`	`350`	`return topicOverviewDTO;`
`351`	`351`	`}`