diff --git a/kafka_exporter.go b/kafka_exporter.go index 36021149..6abac6a5 100644 --- a/kafka_exporter.go +++ b/kafka_exporter.go @@ -581,7 +581,7 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) { assignment, err := member.GetMemberAssignment() if err != nil { klog.Errorf("Cannot get GetMemberAssignment of group member %v : %v", member, err) - return + continue } for topic, partions := range assignment.Topics { for _, partition := range partions {