并发性

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

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

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