Create example camel-salesforce connector

[valdar]

[Nayananga]

Hi, may I take this task?

[oscerd]

Sure

[Nayananga]

Hi when I was following the guide in here I used ./mnvw install

command to build the project. Then I encountered this error

Error: Could not find or load main class org.apache.maven.wrapper.MavenWrapperMain Caused by: java.lang.ClassNotFoundException: org.apache.maven.wrapper.MavenWrapperMain

I was able to solve this by using

mvn -N io.takari:maven:wrapper
./mnvw install

is this a possible issue to create a new Github issue?

[oscerd]

I think it's because you're on Windows, or at least I guess. Use ./mvnw.cmd in your case

[Nayananga]

No this happened inside a docker container (ubuntu 18.04). I'll try using ./mvnw.cmd Thanks :)

[Nayananga]

Hi, @oscerd I found that almost every connector.properties file has

camel.source.url

and

camel.sink.url

what are these stands for? thanks

[oscerd]

Sink stands for a camel producer endpoint uri, while source stands for a camel consumer endpoint uri

[oscerd]

To use the camel-kafka-connector you need the basic camel knowledge

[valdar]

The itest has already been done.

[kidpollo]

I'm trying to use the salesforce source connector and based on what I can see on the tests I am unable to get anything from salesforce. It seems that the connector authenticates properly but as I try to get stuff from /data/AccountChangeEvent nothing happens. No errors no nothing. Using an alternate comet client I am able to see the cdc events. On an interesting note if I provide an invalid topicName config there is no error also. This the config I am using

name = sfdc_test
connector.class = org.apache.camel.kafkaconnector.salesforce.CamelSalesforceSourceConnector
topics = camel-sfdc-stream
camel.source.path.topicName = /data/AccountChangeEvent
camel.source.endpoint.rawPayload = true
camel.source.endpoint.replayId = -2
camel.component.salesforce.apiVersion = 50.0
camel.component.salesforce.authenticationType = USERNAME_PASSWORD
camel.component.salesforce.clientId =  <redacted>
camel.component.salesforce.clientSecret = <redacted>
camel.component.salesforce.loginUrl = https://login.salesforce.com
camel.component.salesforce.password = <redacted>
camel.component.salesforce.userName = <redacted>

Also note that on the same kc i have another camel connector that does work properly. The AWS SQS source connector.