|
对于最新稳定版本，请使用spring-cloud-stream 5.0.1！ |
并发
当与响应式 Kafka 绑定器一起使用响应式函数时，如果在消费者绑定上设置并发性，则绑定器会创建所提供值数量的专用KafkaReceiver对象。
换句话说，这会创建多个单独的Flux实现的反应流。
这对从分区主题中消耗记录非常有用。
例如，假设传入的主题至少有三个分区。 那么您可以设置以下属性。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3这将创建三个专用的KafkaReceiver对象，它们生成三个单独的Flux实现，并将其流式传输到处理程序方法。