0

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

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

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

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

4

1 回答 1

1

最好使用多个接收器。

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

于 2021-05-06T14:11:03.353 回答