本站内所有文档均为中英对照文档，点击中文可以显示英文。此提醒连续关闭5次后，将不再显示。
并发
在使用响应式Kafka绑定器时，如果为消费者绑定设置并发度，绑定器将根据并发值创建相应数量的专用 KafkaReceiver 对象。换句话说，这会创建多个具有独立 Flux 实现的响应式流。当您从分区主题消费记录时，这可能非常有用。
例如，假设传入的主题至少有三个分区。那么你可以设置以下属性。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3
这将创建三个专用的 KafkaReceiver 对象，它们会生成三个独立的 Flux 实现，然后将它们流式传输到处理方法中。