我有一个基于 webFlux 的服务,将使用然后从 kafka 主题生成消息。我的代码就是这样
@Bean
public Function<Flux<String>, Flux<String>> reactiveUpperCase() {
return flux -> flux.map(val -> val.toUpperCase());
}
我发现当我有 2 个实例时,我每 30 分钟可以消耗 750 条消息,但我的 CPU 从未高于 10%。随着时间的推移,延迟不断增加,所以我想知道如何增加消费者吞吐量。从文档来看,并发对反应性无效,链接
有谁知道如何在不添加更多实例的情况下增加吞吐量?