并发

DeepSeek V3 中英对照 Concurrency

在使用反应式函数与反应式 Kafka 绑定器时，如果在消费者绑定上设置了并发性（concurrency），那么绑定器会创建与并发值相同数量的专用 KafkaReceiver 对象。换句话说，这将创建多个具有独立 Flux 实现的反应式流。当您从分区主题消费记录时，这可能会非常有用。

例如，假设传入的主题至少有三个分区。那么你可以设置以下属性。

spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3

none

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