Handle Azure Eventhubs returns list duplicated servers

danielqsj · Jul 10, 2024 · 0e29a0a · 0e29a0a
1 parent 7ba4ae8
commit 0e29a0a
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -661,9 +661,23 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 
 	klog.V(DEBUG).Info("Fetching consumer group metrics")
 	if len(e.client.Brokers()) > 0 {
+		uniqueBrokerAddresses := make(map[string]bool)
+		var servers []string
 		for _, broker := range e.client.Brokers() {
-			wg.Add(1)
-			go getConsumerGroupMetrics(broker)
+			normalizedAddress := strings.ToLower(broker.Addr())
+			if !uniqueBrokerAddresses[normalizedAddress] {
+				uniqueBrokerAddresses[normalizedAddress] = true
+				servers = append(servers, broker.Addr())
+			}
+		}
+		klog.Info(servers)
+		for _, broker := range e.client.Brokers() {
+			for _, server := range servers {
+				if server == broker.Addr() {
+					wg.Add(1)
+					go getConsumerGroupMetrics(broker)
+				}
+			}
 		}
 		wg.Wait()
 	} else {