并发

在使用响应式函数配合响应式Kafka绑定器时,如果你在消费级绑定上设置并发,绑定器就会生成尽可能多的专用绑定卡夫卡接收器对象由并发值提供。换句话说,这会创建多个响应式流,分别是独立的通量实现。 当你从分区主题中获取记录时,这可能非常有用。spring-doc.cadn.net.cn

例如,假设进入的主题至少有三个分区。然后你可以设置以下性质。spring-doc.cadn.net.cn

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

这样就有三个专门的卡夫卡接收器生成三个独立对象通量实现,然后将它们流式传输到处理器方法。spring-doc.cadn.net.cn