(camel) branch main updated: CAMEL-21740: added error handling for corrupt replay ids

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new c9f9f237089 CAMEL-21740: added error handling for corrupt replay ids
c9f9f237089 is described below

commit c9f9f2370890e0d8fad4359ef51aad65a4aa8c01
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun Feb 16 11:14:43 2025 +0100

    CAMEL-21740: added error handling for corrupt replay ids
---
 .../camel/component/salesforce/internal/client/PubSubApiClient.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
index e500e7c9c4c..337f137f95e 100644
--- 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
+++ 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/PubSubApiClient.java
@@ -73,7 +73,8 @@ public class PubSubApiClient extends ServiceSupport {
 
     public static final String PUBSUB_ERROR_AUTH_ERROR = 
"sfdc.platform.eventbus.grpc.service.auth.error";
     private static final String PUBSUB_ERROR_AUTH_REFRESH_INVALID = 
"sfdc.platform.eventbus.grpc.service.auth.refresh.invalid";
-    private static final String PUBSUB_ERROR_CORRUPTED_REPLAY_ID = 
"sfdc.platform.eventbus.grpc.subscription.fetch.replayid.corrupted";
+    private static final String PUBSUB_ERROR_CORRUPTED_REPLAY_ID
+            = 
"sfdc.platform.eventbus.grpc.subscription.fetch.replayid.corrupted";
 
     protected PubSubGrpc.PubSubStub asyncStub;
     protected PubSubGrpc.PubSubBlockingStub blockingStub;
@@ -345,7 +346,8 @@ public class PubSubApiClient extends ServiceSupport {
                             LOG.debug("logged in {}", consumer.getTopic());
                         }
                         case PUBSUB_ERROR_CORRUPTED_REPLAY_ID -> {
-                            LOG.error("replay id is corrupt. try resubscribing 
with LATEST replay preset");
+                            LOG.error("replay id: " + replayId
+                                      + " is corrupt. Trying to recover by 
resubscribing with LATEST replay preset");
                             replayId = null;
                             initialReplayPreset = ReplayPreset.LATEST;
                         }