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