Skip to content

Commit 911b783

Browse files
alexander-falcaamuraru
authored andcommitted
Colelct offsets for EMPTY groups
1 parent ca008cf commit 911b783

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

minion/consumer_group_offsets.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ func (s *Service) ListAllConsumerGroupOffsetsAdminAPI(ctx context.Context) (map[
2424
}
2525
groupIDs := make([]string, len(groupsRes.AllowedGroups.Groups))
2626
for i, group := range groupsRes.AllowedGroups.Groups {
27-
if group.GroupState != "Empty" && group.GroupState != "Dead" {
27+
if group.GroupState != "Dead" {
2828
groupIDs[i] = group.Group
2929
}
3030
}

0 commit comments

Comments
 (0)