Concurrency

对反应式 Kafka 绑定程序使用反应式函数时，如果在 consumer 绑定上设置并发，那么绑定程序就创建与并发值提供的相同数量的专用 KafkaReceiver 对象。换句话说，这会创建具有独立 Flux 实现的多个反应式流。当从分区主题使用记录时，这可能会很有用。

例如，假设传入主题至少有三个分区。然后可以设置以下属性。

这会创建三个专用 KafkaReceiver 对象，这些对象生成三个独立的 Flux 实现，然后将它们流式传输到处理程序方法。