Increase membersWithEmptyAssignment when MemberAssignment is empty

Signed-off-by: Michal Padula <michal.padula@outlook.com>
redpanda-data · Apr 4, 2022 · a4cbed2 · a4cbed2
1 parent 2a62a9d
commit a4cbed2
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",