Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-15996

camel-salesforce:change data capture issue

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Invalid
    • 2.24.0
    • None
    • camel-salesforce
    • None
    • Unknown
    • Unit Test Broken

    Description

      I am trying to receive salesforce change data capture event body from salesforce, but receiving null (empty message) value when there is any update on Account object, expecting complete response body. Can you please help, which version that I am supposed to use?

      <dependencyManagement>                 <dependencies>                          <dependency>                                   <groupId>org.apache.camel</groupId>                                   <artifactId>camel-spring-boot-dependencies</artifactId>                                   <version>2.24.0</version>                                    <type>pom</type>                                   <scope>import</scope>                          </dependency>                 </dependencies>         </dependencyManagement>

       

      Here is complete route builder

      @Component

          class EventConsumerRouteBuilder extends RouteBuilder {

              @Override

              public void configure() throws Exception {

       

                  SalesforceEndpointConfig config = new SalesforceEndpointConfig();

                  config.setApiVersion("49.0");

                  SalesforceComponent component = this.getContext().getComponent("salesforce", SalesforceComponent.class);

                  component.setConfig(config);

       

                  from("salesforce:event/Order_Event__e?replayId=-1&rawPayload=true")

                          .log("Platform Event Received: ${body}");

                 

                  //from("salesforce:data/AccountChangeEvent?replayId=-1&rawPayload=true")

                  from("salesforce:data/AccountChangeEvent?replayId=-1")

                  .log("CDC Event Received: ${body}");

                 

              }

          }

      Below are logs, I am using api version "45.0" and camel version "2.24.0". 2020-12-22 08:21:22.225  INFO 27340 — [ent@6475472c-48] o.a.c.c.s.i.s.SubscriptionHelper         : Subscribed to channel /data/AccountChangeEvent2020-12-22 08:23:11.596 DEBUG 27340 — [ent@6475472c-46] o.a.c.c.s.i.s.SubscriptionHelper$5       : Received messages [\{clientId=h3ectdw6piysatb1a1t7s1bopn5q, channel=/meta/connect, id=3, successful=true}]2020-12-22 08:23:11.596 DEBUG 27340 — [ent@6475472c-46] o.a.c.c.s.i.s.SubscriptionHelper         : [CHANNEL:META_CONNECT]: {clientId=h3ectdw6piysatb1a1t7s1bopn5q, channel=/meta/connect, id=3, successful=true}2020-12-22 08:23:56.036 DEBUG 27340 — [ent@6475472c-45] o.a.c.c.s.i.s.SubscriptionHelper$5       : Received messages [{data={schema=qlbfz598kJgHdPdgIoLiLw, payload={LastModifiedDate=2020-12-22T13:23:57.000Z, Full_Account_Name_c=Test1234rc, ChangeEventHeader={commitNumber=10724561884739, commitUser=00556000004IScuAAG, sequenceNumber=1, entityName=Account, changeType=UPDATE, changedFields=[Ljava.lang.Object;@409e2f60, changeOrigin=com/salesforce/api/soap/50.0;client=SfdcInternalAPI/, transactionKey=0008ea61-2c18-977d-6f6f-a853fecd091a, commitTimestamp=1608643437000, recordIds=[Ljava.lang.Object;@2baf97bc}}, event=\{replayId=29127}}, channel=/data/AccountChangeEvent}, \{clientId=h3ectdw6piysatb1a1t7s1bopn5q, channel=/meta/connect, id=5, successful=true}]2020-12-22 08:23:56.036 DEBUG 27340 — [ent@6475472c-45] o.a.c.c.s.i.s.SubscriptionHelper         : Received Message: {data={schema=qlbfz598kJgHdPdgIoLiLw, payload={LastModifiedDate=2020-12-22T13:23:57.000Z, Full_Account_Name_c=Test1234rc, ChangeEventHeader={commitNumber=10724561884739, commitUser=00556000004IScuAAG, sequenceNumber=1, entityName=Account, changeType=UPDATE, changedFields=[Ljava.lang.Object;@409e2f60, changeOrigin=com/salesforce/api/soap/50.0;client=SfdcInternalAPI/, transactionKey=0008ea61-2c18-977d-6f6f-a853fecd091a, commitTimestamp=1608643437000, recordIds=[Ljava.lang.Object;@2baf97bc}}, event={replayId=29127}}, channel=/data/AccountChangeEvent}2020-12-22 08:23:56.040 DEBUG 27340 — [ent@6475472c-45] o.a.c.c.salesforce.SalesforceConsumer    : Received event /data/AccountChangeEvent on channel /data/AccountChangeEvent2020-12-22 08:23:56.062 DEBUG 27340 — [ent@6475472c-45] o.a.c.c.salesforce.SalesforceConsumer    : Received SObject: null2020-12-22 08:23:56.079  INFO 27340 — [ent@6475472c-45] testLog                                  : Exchange[Id: ID-LATL-4SV4KR2-1608643268617-0-1, ExchangePattern: InOnly, Properties: {CamelCreatedTimestamp=Tue Dec 22 08:23:56 EST 2020, CamelExternalRedelivered=false, CamelMessageHistory=[DefaultMessageHistory[routeId=route1, node=to1]], CamelToEndpoint=log://testLog?showAll=true}, Headers: {breadcrumbId=ID-LATL-4SV4KR2-1608643268617-0-1, CamelSalesforceChannel=/data/AccountChangeEvent, CamelSalesforceCreatedDate=null, CamelSalesforceEventType=null, CamelSalesforceReplayId=29127, CamelSalesforceTopicName=data/AccountChangeEvent}, BodyType: String, Body: null, Out: null: ]2020-12-22 08:23:56.086 DEBUG 27340 — [ent@6475472c-45] o.a.c.c.s.i.s.SubscriptionHelper         : [CHANNEL:META_CONNECT]: {clientId=h3ectdw6piysatb1a1t7s1bopn5q, channel=/meta/connect, id=5, successful=true}

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            rcrama Ravi Rama
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: