併發

當將響應式函式與響應式 Kafka 繫結器一起使用時,如果您在消費者繫結上設定了併發數,那麼繫結器將建立與併發數值一樣多的專用 KafkaReceiver 物件。換句話說,這會建立多個具有獨立 Flux 實現的響應式流。當您從分割槽主題消費記錄時,這可能很有用。

例如,假設傳入主題至少有三個分割槽。那麼您可以設定以下屬性。

spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3

這將建立三個專用的 KafkaReceiver 物件,它們生成三個獨立的 Flux 實現,然後將它們流式傳輸到處理方法。

© . This site is unofficial and not affiliated with VMware.