Fixed scenario where consumers may not have assignments in Consumer G…

…roups
danielqsj · Mar 14, 2024 · 84b3176 · 84b3176
1 parent b66d284
commit 84b3176
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -578,6 +578,10 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 				}
 			} else {
 				for _, member := range group.Members {
+					if len(member.MemberAssignment) == 0 {
+						klog.Warningf("MemberAssignment is empty for group member: %v in group: %v", member.MemberId, group.GroupId)
+						continue
+					}
 					assignment, err := member.GetMemberAssignment()
 					if err != nil {
 						klog.Errorf("Cannot get GetMemberAssignment of group member %v : %v", member, err)