并发

当使用响应式 Kafka 绑定器与响应式函数时，如果在消费者绑定上设置并发性，则绑定器会创建与并发性值提供的数量一样多的专用 KafkaReceiver 对象。换句话说，这会创建多个具有独立 Flux 实现的响应式流。当您从分区主题中消费记录时，这可能很有用。

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

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