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

Author: amuraru

e2e/producer.go

@@ -61,7 +61,7 @@ func (s *Service) produceMessage(ctx context.Context, partition int) {
 			msg.state = EndToEndMessageStateProducedSuccessfully
 			msg.produceLatency = ackDuration.Seconds()
 
-			// TODO: Enable again as soon as https://github.com/ReneKroon/ttlcache/issues/60 is fixed
+			// TODO: Enable again as soon as https://github.com/jellydatora/ttlcache/issues/60 is fixed
 			// Because we cannot update cache items in an atomic fashion we currently can't use this method
 			// as this would cause a race condition which ends up in records being reported as lost/expired.
 			// s.messageTracker.updateItemIfExists(msg)

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 != "Dead" {
+			groupIDs[i] = group.Group
+		}
 	}
 
 	return s.listConsumerGroupOffsetsBulk(ctx, groupIDs)