diff --git a/api/grpc/grpc.go b/api/grpc/grpc.go index 48d7b54ab..4b4c4b630 100644 --- a/api/grpc/grpc.go +++ b/api/grpc/grpc.go @@ -60,7 +60,10 @@ func (a *apiImpl) connectToLocalEndpoint() (*grpc.ClientConn, error) { } func (a *apiImpl) Start() { - grpcServer := grpc.NewServer(grpc.ChainUnaryInterceptor(a.config.UnaryInterceptors...)) + grpcServer := grpc.NewServer( + grpc.ChainUnaryInterceptor(a.config.UnaryInterceptors...), + grpc.MaxConcurrentStreams(100), + ) for _, serv := range a.apiServices { serv.RegisterServiceServer(grpcServer) }