Merge pull request danielqsj#291 from echernous/fix/topic-metadata-wo…

…rkers Fix number of workers
foxdalas · Jan 18, 2022 · 6e14e80 · 6e14e80
2 parents 15e4ad6 + b373e46
commit 6e14e80
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -511,7 +511,11 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 		}
 	}
 
-	N := minx(len(topics)/2, e.topicWorkers)
+	N := len(topics)
+	if N > 1 {
+		N = minx(N/2, e.topicWorkers)
+	}
+
 	for w := 1; w <= N; w++ {
 		go loopTopics(w)
 	}