spring 集成流 dsl 性能缓慢 [关闭]

Question

public IntegrationFlow processEvent() {
        return IntegrationFlow.from(Consumer.class, gateway -> gateway.beanName("onMessage"))
                    .transform(Transformers.fromJson(Alert.class))
                .log(LoggingHandler.Level.DEBUG, "Message Routed to DB store", t -> t.toString())
                .routeToRecipients(r -> r
                        .recipient(persistenceRouteChannel()))                      
                .get();
    }

我的用例是从 pubsub 中提取记录并将其放入 postgresdb。 但是使用 spring 集成流程需要很长时间才能插入 1000 条记录，大约需要 15 分钟。 我使用 spring.cloud.gcp.pubsub.subscriber.executor-threads 创建了多个线程和 spring.cloud.gcp.pubsub.subscriber.parallel-pull-count 。线程仍然是处于停放状态的线程。有没有办法为集成流分配多个线程或并行处理