Merge pull request #429 from sciclon2/bugfix/consumer-assignments-issue

fix: Fixing Issue with Member Assignments in Consumer Group
danielqsj · Aug 20, 2024 · 3b37dc8 · 3b37dc8
2 parents 8eee667 + 84b3176
commit 3b37dc8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka_exporter.go b/kafka_exporter.go
@@ -583,6 +583,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)