issue#409: skip error group members

danielqsj · May 15, 2024 · a0de138 · a0de138
1 parent 2e60c05
commit a0de138
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 {