You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2021/11/16 09:04:34 UTC
[GitHub] [camel-kafka-connector] milkchocolate opened a new issue #1290: The pre-release salesforce source connector, the received messages are in the format that different from Salesforce document.
milkchocolate opened a new issue #1290:
URL: https://github.com/apache/camel-kafka-connector/issues/1290
Hi team,
When I use the salesforce source connector, the received messages are in the format below
```json
{
"schema":{
"type":"bytes",
"optional":false
},
"payload":"eyJMYXN0TW9kaWZpZWREYXRlIjoiMjAyMS0xMS0xNlQwNzozMjoxMC4wMDBaIiwiV2luX1Byb2JhYmlsaXR5X19jIjozMC4wfQ=="
}
```
The base64 decoded payload
```json
{
"LastModifiedDate":"2021-11-16T07:32:10.000Z",
"Win_Probability__c":30.0
}
```
This Salesforce document says the messages are in the format below, when I use the example connector from the document, I can receive messages in that format. How can I get other fields back if I use the pre-release Camel Salesforce Source Connector?
https://trailhead.salesforce.com/en/content/learn/modules/change-data-capture/subscribe-to-events
```json
{
"schema": "-pszPCNGMHqUPU1ftkjxEA",
"payload": {
"LastModifiedDate": "2019-09-25T20:38:11.000Z",
"ChangeEventHeader": {
"commitNumber": 65840825286,
"commitUser": "005RM000001vI4mYAE",
"sequenceNumber": 1,
"entityName": "Employee__c",
"changeType": "UPDATE",
"changedFields": [
"LastModifiedDate",
"First_Name__c",
"Tenure__c"
],
"changeOrigin": "com/salesforce/api/soap/47.0;client=SfdcInternalAPI/",
"transactionKey": "00051d4a-7640-5b8c-c6d1-b8db4ce4cf2f",
"commitTimestamp": 1569443892000,
"recordIds": [
"a00RM0000004ICTYA2"
]
},
"First_Name__c": "Trish",
"Tenure__c": 3.0
},
"event": {
"replayId": 15054
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] hakidehari commented on issue #1290: The pre-release salesforce source connector, the received messages are in the format that different from Salesforce document.
Posted by GitBox <gi...@apache.org>.
hakidehari commented on issue #1290:
URL: https://github.com/apache/camel-kafka-connector/issues/1290#issuecomment-1040833022
In your config, do you have rawPayload set to true? Also, what type of event is this: a platform event or a change data capture event?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kafka-connector] hakidehari edited a comment on issue #1290: The pre-release salesforce source connector, the received messages are in the format that different from Salesforce document.
Posted by GitBox <gi...@apache.org>.
hakidehari edited a comment on issue #1290:
URL: https://github.com/apache/camel-kafka-connector/issues/1290#issuecomment-1040833022
In your config, do you have rawPayload set to true? Also, what type of event is this: a platform event or a change data capture event? You may also have to disable schemas.enable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org