CODEWITHSUNDEEP
javaspring-bootapache-camelsalesforce
user1346346
user1346346

Reputation: 369

camel Producer Template - Buffering capacity 4194304 exceeded

We are using Java 17, Spring Boot 3.3.1 and Apache camel 4.8.0 in the project.

We are using camel salesforce component to communicate with Salesforce.

https://camel.apache.org/components/4.8.x/salesforce-component.html#bulk2GetSuccessfulResults https://github.com/apache/camel/blob/camel-4.2.0/components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/BulkApiV2IngestJobIntegrationTest.java

InputStream is = producerTemplate.requestBodyAndHeader("salesforce:bulk2GetSuccessfulResults", "", "jobId", jobId, InputStream.class);
List<String> records = IOUtils.readLines(is, StandardCharsets.UTF_8);

As I tried to get the success result of the batch job( using camel salesforce component, bulk api 2), I am getting the below error. I am getting this error only the result size(around 100000) is huge.

org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[] at org.apache.camel.CamelExecutionException.wrapCamelExecutionException(CamelExecutionException.java:45) at org.apache.camel.support.ExchangeHelper.extractResultBody(ExchangeHelper.java:692) at org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:591) at org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:587) at org.apache.camel.impl.engine.DefaultProducerTemplate.requestBodyAndHeader(DefaultProducerTemplate.java:431) . at org.apache.camel.impl.engine.CamelInternalProcessor.processNonTransacted(CamelInternalProcessor.java:347) at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:323) . at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: org.apache.camel.component.salesforce.api.SalesforceException: Unexpected error {200:OK} executing {GET:https://sbc--uat.sandbox.my.salesforce.com/services/data/v49.0/jobs/ingest/650O400000EpSR1IAN/successfulResults} at org.apache.camel.component.salesforce.internal.client.AbstractClientBase$1.lambda$onComplete$1(AbstractClientBase.java:226) ... 3 more Caused by: java.lang.IllegalArgumentException: Buffering capacity 4194304 exceeded at org.eclipse.jetty.client.BufferingResponseListener.onContent(BufferingResponseListener.java:116) at org.eclipse.jetty.client.Response$ContentListener.onContent(Response.java:161)

How to resolve this issue?

Upvotes: 0

Views: 16

Answers (0)

Related Questions