并发

当对 Reactive Kafka 绑定器使用响应式函数时,如果你在消费者绑定上设置了并发,那么绑定器会创建与并发值数量相同的专用 KafkaReceiver 对象。换句话说,这会创建多个具有独立 Flux 实现的响应式流。当你从分区主题消费记录时,这会很有用。

例如,假设传入主题至少有三个分区。那么你可以设置以下属性。

spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3

这将创建三个专用的 KafkaReceiver 对象,它们生成三个独立的 Flux 实现,然后将它们流式传输到处理程序方法。