270.8.2. Backpressure(소비자 측면) 제어

Camel이 reactive-streams 게시자의 항목을 사용하는 경우, 광대 교환의 최대 개수를 엔드포인트 옵션으로 설정할 수 있습니다.

소비자와 관련된 구독자는 게시자와 상호 작용하여 경로의 메시지 수를 임계값보다 낮게 유지합니다.

백압 인식 경로의 예는 다음과 같습니다.

from("reactive-streams:numbers?maxInflightExchanges=10")
.to("direct:endpoint");

Camel이 소스 게시자에 요청한 항목 수(활성 스트림 백압 메커니즘을 통해)는 항상 10 보다 낮습니다. 메시지는 Camel 측의 단일 스레드에서 처리합니다.

동시 소비자 수(스레일스)는 엔드포인트 옵션(concurrentConsumers)으로 설정할 수도 있습니다. 1 소비자(기본값)를 사용하는 경우 소스 스트림의 항목 순서가 유지됩니다. 이 값이 증가하면 여러 스레드에서 항목을 동시에 처리합니다(주문을 유지하지 않도록).