併發
當與響應式 Kafka Binder 一起使用響應式函式時,如果在消費者繫結上設定了併發度,Binder 會建立與併發度值相同數量的專用 KafkaReceiver
物件。換句話說,這會建立多個具有獨立 Flux
實現的響應式流。這在從分割槽主題消費記錄時非常有用。
例如,假設傳入主題至少有三個分割槽。那麼可以設定以下屬性。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3
這將建立三個專用的 KafkaReceiver
物件,它們生成三個獨立的 Flux
實現,然後將它們流式傳輸到處理方法。