Skip to content

Commit 22feccb

Browse files
committed
fix: add error check when there is no assignment
1 parent 9ac8c1a commit 22feccb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

cmd/kaf/topic.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -368,7 +368,10 @@ var lagCmd = &cobra.Command{
368368
var lagInfo = make(map[string]int64)
369369
for _, v := range groupsInfo {
370370
for _, member := range v.Members {
371-
assignment, _ := member.GetMemberAssignment()
371+
assignment, err := member.GetMemberAssignment()
372+
if err != nil || assignment == nil {
373+
continue
374+
}
372375
if _, exist := assignment.Topics[topic]; exist {
373376
var sum int64
374377
resp, _ := admin.ListConsumerGroupOffsets(v.GroupId, assignment.Topics)

0 commit comments

Comments
 (0)