fixed cgroup producers

pecanNBU · Jun 2, 2020 · ca95aee · ca95aee
1 parent 042f8f0
commit ca95aee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/quartz/TopicRankQuartz.java b/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/quartz/TopicRankQuartz.java
@@ -344,9 +344,9 @@ private void topicProducerLogSizeStats() {
 
 		List<TopicRank> topicRanks = new ArrayList<>();
 		List<TopicLogSize> topicLogSizes = new ArrayList<>();
-		long producerThreads = 0L;
 		String[] clusterAliass = SystemConfigUtils.getPropertyArray("kafka.eagle.zk.cluster.alias", ",");
 		for (String clusterAlias : clusterAliass) {
+			long producerThreads = 0L;
 			List<String> topics = brokerService.topicList(clusterAlias);
 			for (String topic : topics) {
 				long logsize = brokerService.getTopicProducerLogSize(clusterAlias, topic);