Skip to content

Commit fb7cf1a

Browse files
authored
Merge pull request #441 from showuon/409
Fix issue#409: skip error group members
2 parents 2e60c05 + a0de138 commit fb7cf1a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

kafka_exporter.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -569,6 +569,10 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
569569
return
570570
}
571571
for _, group := range describeGroups.Groups {
572+
if group.Err != 0 {
573+
klog.Errorf("Cannot describe for the group %s with error code %d", group.GroupId, group.Err)
574+
continue
575+
}
572576
offsetFetchRequest := sarama.OffsetFetchRequest{ConsumerGroup: group.GroupId, Version: 1}
573577
if e.offsetShowAll {
574578
for topic, partitions := range offset {

0 commit comments

Comments
 (0)