Merge pull request #142 from Sh1ftry/empty-members-assignment

Increase membersWithEmptyAssignment when MemberAssignment is empty
redpanda-data · Apr 25, 2022 · 4fbec9a · 4fbec9a
2 parents 2a62a9d + a4cbed2
commit 4fbec9a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/prometheus/collect_consumer_groups.go b/prometheus/collect_consumer_groups.go
@@ -68,6 +68,11 @@ func (e *Exporter) collectConsumerGroups(ctx context.Context, ch chan<- promethe
 			membersWithEmptyAssignment := 0
 			failedAssignmentsDecode := 0
 			for _, member := range group.Members {
+				if len(member.MemberAssignment) == 0 {
+					membersWithEmptyAssignment++
+					continue
+				}
+
 				kassignment, err := decodeMemberAssignments(group.ProtocolType, member)
 				if err != nil {
 					e.logger.Debug("failed to decode consumer group member assignment, internal kafka error",