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