並行性
當搭配反應式 Kafka binder 使用反應式函數時,如果您在消費者繫結上設定並行性,則 binder 會建立與並行性值提供的數量一樣多的專用 KafkaReceiver
物件。換句話說,這會建立具有獨立 Flux
實作的多個反應式串流。當您從分割主題消費記錄時,這可能會很有用。
例如,假設傳入的主題至少有三個分割區。然後您可以設定下列屬性。
spring.cloud.stream.bindings.lowercase-in-0.consumer.concurrency=3
這將建立三個專用的 KafkaReceiver
物件,這些物件會產生三個獨立的 Flux
實作,然後將它們串流到處理常式方法。