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