并发
当对 Reactive Kafka 绑定器使用响应式函数时,如果你在消费者绑定上设置了并发,那么绑定器会创建与并发值数量相同的专用 KafkaReceiver
对象。换句话说,这会创建多个具有独立 Flux
实现的响应式流。当你从分区主题消费记录时,这会很有用。
例如,假设传入主题至少有三个分区。那么你可以设置以下属性。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3
这将创建三个专用的 KafkaReceiver
对象,它们生成三个独立的 Flux
实现,然后将它们流式传输到处理程序方法。