spring cloud流Kafka Reactive流分区分配如何与并发处理一起工作

Question

例如，我配置一个主题有两个分区，但在我的应用程序中，有一个实例，我使用Flux.parallel(10)来消费消息，而它在该主题上有1000个消息滞后，会发生什么？

1. 它会每次轮询10条消息吗？从2个分区还是1个分区
2. 每个只轮询2条消息和1个分区

我想知道它是如何工作的，这样我就可以将其配置为具有大吞吐量和消耗序列的能力

顺便说一句，我发现了这个问题，但现在在那里回答

Answer 1

最好使用多个接收器。

使用并行可能会导致偏移量提交出现问题。