Merge pull request #441 from showuon/409

Fix issue#409: skip error group members
danielqsj · May 24, 2024 · fb7cf1a · fb7cf1a
2 parents 2e60c05 + a0de138
commit fb7cf1a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -569,6 +569,10 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 			return
 		}
 		for _, group := range describeGroups.Groups {
+			if group.Err != 0 {
+				klog.Errorf("Cannot describe for the group %s with error code %d", group.GroupId, group.Err)
+				continue
+			}
 			offsetFetchRequest := sarama.OffsetFetchRequest{ConsumerGroup: group.GroupId, Version: 1}
 			if e.offsetShowAll {
 				for topic, partitions := range offset {