[INTERNAL] Don't report offsets and lag for empty consumer groups

amuraru · amuraru · commit 250e9fb75079 · 2021-12-22T18:15:31.000+02:00
diff --git a/minion/consumer_group_offsets.go b/minion/consumer_group_offsets.go
@@ -24,7 +24,9 @@ func (s *Service) ListAllConsumerGroupOffsetsAdminAPI(ctx context.Context) (map[
 	}
 	groupIDs := make([]string, len(groupsRes.AllowedGroups.Groups))
 	for i, group := range groupsRes.AllowedGroups.Groups {
-		groupIDs[i] = group.Group
+		if group.GroupState != "Empty" && group.GroupState != "Dead" {
+			groupIDs[i] = group.Group
+		}
 	}
 
 	return s.listConsumerGroupOffsetsBulk(ctx, groupIDs)

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,9 @@ func (s *Service) ListAllConsumerGroupOffsetsAdminAPI(ctx context.Context) (map[`
`24`	`24`	`}`
`25`	`25`	`groupIDs := make([]string, len(groupsRes.AllowedGroups.Groups))`
`26`	`26`	`for i, group := range groupsRes.AllowedGroups.Groups {`
`27`		`- groupIDs[i] = group.Group`
	`27`	`+ if group.GroupState != "Empty" && group.GroupState != "Dead" {`
	`28`	`+ groupIDs[i] = group.Group`
	`29`	`+ }`
`28`	`30`	`}`
`29`	`31`
`30`	`32`	`return s.listConsumerGroupOffsetsBulk(ctx, groupIDs)`