apoorvmintri commented on issue #1587:
URL:
https://github.com/apache/camel-kafka-connector/issues/1587#issuecomment-1903530176
#### Workaround
Realizing that the "operationName" property was added in v3.19.x, I switch
to 3.18.x (I used the latest - v3.18.2). And my json was the same as Version 2
(described in the problem) -
`{ "name": "sf-source-connector", "config": { "tasks.max":"1",
"connector.class":"org.apache.camel.kafkaconnector.salesforcesource.CamelSalesforcesourceSourceConnector",
"key.converter":"org.apache.kafka.connect.storage.StringConverter",
"value.converter":"org.apache.kafka.connect.storage.StringConverter",
"camel.kamelet.salesforce-source.query": "SELECT * FROM Account",
"camel.kamelet.salesforce-source.topicName":
"subscribe:/data/AccountChangeEvent",
"camel.kamelet.salesforce-source.loginUrl": "https://login.salesforce.com/";,
"camel.kamelet.salesforce-source.clientId": "<Redacted>",
"camel.kamelet.salesforce-source.clientSecret": "<Redacted>",
"camel.kamelet.salesforce-source.userName": "<Redacted>",
"camel.kamelet.salesforce-source.password": "<Redacted>",
"camel.kamelet.salesforce-source.notifyForOperationCreate": "true",
"camel.kamelet.salesforce-source.notifyForOperationUpdate": "true",
"camel.kamelet.salesforce-source.notifyForOperationDelete": "true",
"camel.kamelet.salesf
orce-source.notifyForOperationUndelete": "true",
"camel.source.endpoint.rawPayload": "true", "topics": "camelsfstream" } }`
Note -
`"camel.kamelet.salesforce-source.operation": "subscribe"` is removed &
`"camel.kamelet.salesforce-source.topicName":
"subscribe:/data/AccountChangeEvent"` prefix 'subscribe:' added to topic
I did face Authorization Failure, which was resolved by going to Salesforce
Setup > OAuth and OpenId Connect Settings, and enabling 'Allow OAuth
Usename-Password Flows'. Just FYI, there are other policies that should be
setup in your salesforce connected app to make this connection succeful.
After this, I faced the infamous `InputStreamCache` messages in my kafka
instance instead of the actual data, as described in issue #1433 . To resolve
this, the following workaround I described here works -
<https://github.com/apache/camel-kafka-connector/issues/1433#issuecomment-1903471389>
--
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-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
