Невозможно использовать событие из события платформы Salesforce с помощью Camel Salesforce. ⇐ JAVA

[Anonymous]

Невозможно получить событие из события платформы Salesforce с помощью Camel Salesforce.
Я использую Camel 4.8.0, JDK 17 и Spring Boot 3.3.4.
Я использую приведенный ниже код.

Код: Выделить всё

from("salesforce:pubSubSubscribe:/event/Test_Event__e?pubSubDeserializeType=JSON&pubSubBatchSize=5")
.log("Consumed UMD Platform Event : ${body}");

application.properties

Код: Выделить всё

camel.component.salesforce.login-config.instance-url=https://cbm--dev1.sandbox.my.salesforce.com
camel.component.salesforce.login-config.loginUrl=https://test.salesforce.com
camel.component.salesforce.login-config.clientId=3121hz9IjkO5fmWVBql21yvTDd1cf2zF0iYwAi1Yf3mgMTaxbRh5K2RQj5zCaKpMC1Ug2rZIAngtTbil3Kda
camel.component.salesforce.login-config.userName=integration.user@cbm.com.gen.dev1
camel.component.salesforce.login-config.keystore.resource=file:C:/cbm/00DDC0111108vxk.jks
camel.component.salesforce.login-config.keystore.password=changeit
camel.component.salesforce.login-config.type=JWT
camel.component.salesforce.pub-sub-port=443

Я получаю следующее исключение.

Код: Выделить всё

10:10:03.426  - Starting subscribe /event/Test_Event__e
10:10:03.426  - Subscribing to topic: /event/Test_Event__e.
10:10:03.436  - Subscribe successful.
10:10:03.696  - GRPC Exception
io.grpc.StatusRuntimeException: UNAUTHENTICATED: An authentication exception occurred. Provide valid authentication via metadata headers. rpcId: adf02cb6-cdd5-4aa4-b7fd-da398434a2da
at io.grpc.Status.asRuntimeException(Status.java:533)
at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:481)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:564)
at io.grpc.internal.ClientCallImpl.access$100(ClientCallImpl.java:72)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:729)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:710)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
10:10:03.697  - Trailers:
10:10:03.699  - Trailer: date, Value: Thu, 03 Apr 2025 15:10:04 GMT
10:10:03.699  - Trailer: content-type, Value: application/grpc
10:10:03.699  - Trailer: rpc-id, Value: adf02cb6-cdd5-4aa4-b7fd-da398434a2da
10:10:03.699  - Trailer: error-code, Value: sfdc.platform.eventbus.grpc.service.auth.error
10:10:03.700  - Trailer: type, Value: Subscribe

Обратите внимание, что я сталкиваюсь с этой проблемой только тогда, когда пытаюсь подписаться на событие платформы. Приведенный ниже код работает нормально и без проблем.

Код: Выделить всё

from("timer://foo?fixedRate=true&period=300000")
.to("salesforce:limits")
.log("Salesforce limit detais : ${body}");

Пожалуйста, помогите мне решить эту проблему.

Подробнее здесь: https://stackoverflow.com/questions/795 ... salesforce