You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by "apoorvmintri (via GitHub)" <gi...@apache.org> on 2024/01/22 06:06:17 UTC

[I] Failed to create CamelSalesforcesourceSourceConnector: ResolveEndpointFailedException [camel-kafka-connector]

apoorvmintri opened a new issue, #1587:
URL: https://github.com/apache/camel-kafka-connector/issues/1587

   Background: I am a python developer & have never done Java.
   
   Camel Salesforce Source Connector: v3.20.6 ( I have tried 3.21.0 & 4.0.0 and I'm facing the same issue)
   Kafka: v3.6.1
   
   Issue: Trying to create CamelSalesforcesourceSourceConnector for my kafka instance and it fails with the exception ResolveEndpointFailedException. I have tried a few variations of creating the connector using Kafka's REST API.
   
   Variation 1:
   `{
       "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": "/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.salesforce-source.notifyForOperationUndelete": "true",
           "camel.source.endpoint.rawPayload": "true",
           "camel.kamelet.salesforce-source.operation": "subscribe",
           "topics": "camelsfstream"
       }
   }`
   
   Failure Exception Summary -
   Starts with - `org.apache.kafka.connect.errors.ConnectException: Failed to create and start Camel context\n\tat org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:184)`
   Ends with - `Caused by: java.lang.IllegalArgumentException: /data/AccountChangeEvent\n\tat org.apache.camel.component.salesforce.internal.OperationName.fromValue(OperationName.java:128)\n\tat org.apache.camel.component.salesforce.SalesforceComponent.createEndpoint(SalesforceComponent.java:303)\n\tat org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:171)\n\tat org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:975)`
   
   Key Issue -
   `IllegalArgumentException: /data/AccountChangeEvent`
   
   Variation 2 -
   In my connector I replaced the topic name: `"camel.kamelet.salesforce-source.topicName": "subscribe:/data/AccountChangeEvent"`
   
   The exception starts with `Failed to create and start Camel context`, but the final exception changes to -
   `due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{operationName=subscribe}]`
   
   I am unable to overwrite the endpoint url to test the above variation without the operationName and I am also aware that subscribe is the default. So even if I remove that property from the json, it makes no difference.
   
   On another note the endpoint starts with `local-salesforce-1://` the # increments - is that right? I couldnt find any property to change this. I imagine it gets replaced eventually.


-- 
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.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] Failed to create CamelSalesforcesourceSourceConnector: ResolveEndpointFailedException [camel-kafka-connector]

Posted by "apoorvmintri (via GitHub)" <gi...@apache.org>.

apoorvmintri commented on issue #1587:
URL: https://github.com/apache/camel-kafka-connector/issues/1587#issuecomment-1903574868

   @oscerd The issue is fixed by reverting to 3.18.x, issue persists for 3.19.x and above (incl 4.0.0), unless there is something wrong with my configuration. This is just an fyi, if you still think I should close it, then I will. 


-- 
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

Re: [I] Failed to create CamelSalesforcesourceSourceConnector: ResolveEndpointFailedException [camel-kafka-connector]

Posted by "aonamrata (via GitHub)" <gi...@apache.org>.

aonamrata commented on issue #1587:
URL: https://github.com/apache/camel-kafka-connector/issues/1587#issuecomment-1951967136

   Hi, Any idea when 4.0.4 would be available? I am getting the same error and dont see 4.0.4 in 
   https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-salesforce-source-kafka-connector/ list.


-- 
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