并发

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

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

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