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