diff --git a/components/stargate/internal/server/grpc/api.go b/components/stargate/internal/server/grpc/api.go
index 4a625c3de8..b18445e1ed 100644
--- a/components/stargate/internal/server/grpc/api.go
+++ b/components/stargate/internal/server/grpc/api.go
@@ -82,6 +82,7 @@ func (s *Server) Stargate(stream api.StargateService_StargateServer) error {
 		}...)
 		return status.Errorf(codes.Internal, "cannot subscribe to nats subject")
 	}
+	defer sub.Unsubscribe()
 
 	eg, ctx := errgroup.WithContext(ctx)