fix: add error check when there is no assignment

birdayz · Feb 19, 2024 · 22feccb · 22feccb
1 parent 9ac8c1a
commit 22feccb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cmd/kaf/topic.go b/cmd/kaf/topic.go
@@ -368,7 +368,10 @@ var lagCmd = &cobra.Command{
 		var lagInfo = make(map[string]int64)
 		for _, v := range groupsInfo {
 			for _, member := range v.Members {
-				assignment, _ := member.GetMemberAssignment()
+				assignment, err := member.GetMemberAssignment()
+				if err != nil || assignment == nil {
+					continue
+				}
 				if _, exist := assignment.Topics[topic]; exist {
 					var sum int64
 					resp, _ := admin.ListConsumerGroupOffsets(v.GroupId, assignment.Topics)