We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents f786914 + 22feccb commit 81417e7Copy full SHA for 81417e7
cmd/kaf/topic.go
@@ -368,7 +368,10 @@ var lagCmd = &cobra.Command{
368
var lagInfo = make(map[string]int64)
369
for _, v := range groupsInfo {
370
for _, member := range v.Members {
371
- assignment, _ := member.GetMemberAssignment()
+ assignment, err := member.GetMemberAssignment()
372
+ if err != nil || assignment == nil {
373
+ continue
374
+ }
375
if _, exist := assignment.Topics[topic]; exist {
376
var sum int64
377
resp, _ := admin.ListConsumerGroupOffsets(v.GroupId, assignment.Topics)
0 commit comments