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

问题描述

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

>

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

我想知道它是如何工作的，所以我可以正确配置它具有大吞吐量和消耗序列的能力

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

解决方法

最好使用多个接收器。

使用并行可能会导致无序偏移提交问题。