0

我有一个基于 webFlux 的服务，将使用然后从 kafka 主题生成消息。我的代码就是这样

@Bean
public Function<Flux<String>, Flux<String>> reactiveUpperCase() {
    return flux -> flux.map(val -> val.toUpperCase());
}

我发现当我有 2 个实例时，我每 30 分钟可以消耗 750 条消息，但我的 CPU 从未高于 10%。随着时间的推移，延迟不断增加，所以我想知道如何增加消费者吞吐量。从文档来看，并发对反应性无效，链接

有谁知道如何在不添加更多实例的情况下增加吞吐量？

4

1 回答 1

1

当我使用 kotlin 时，我发现正在使用Flow.flatMapMerge(parallelCount)

于 2021-03-01T02:10:00.670 回答