Kamelet with other components

[2020testuser]

Hi,
Could anyone please help me?
I'm trying to use Kamelet with salesforce.
I applied the kamelet-source-binding.yaml and kamelet-source-binding-kafka.yaml by following the steps in this link.
The link doesn't include details on how to test.
Could anyone please provide details on testing salesforce using kamelet?
Appreciate any help as I'm totally new to this area.

Thanks in advance!

[oscerd]

Hello,what is the link you're talking about?

[2020testuser]

@oscerd - Thanks!
I applied the salesforce-source in the below link.
https://github.com/apache/camel-kamelets/blob/main/salesforce-source.kamelet.yaml

Then, wondering how I can test it... Could you please let me know how I can test salesforce with kamelot? Thanks in advance!

[oscerd]

The only to test the source kamelet is having a developer account at Salesforce.

In the camel-k-examples repo we have some kamelet bindings example, you could start from there: https://github.com/apache/camel-k-examples/tree/main/kamelets

[2020testuser]

@oscerd - Yes, I have a free salesforce account setup by following the instructions in the below link.
https://github.com/apache/camel-k-examples/tree/abf09a0a18c4092430db7501743438035cc8679e/10-knative-source-salesforce

I also, applied the below Kamelet binding using 'Kubectl apply -f ' command. When I create a new contact created in salesforce site , I don't see anything in the log.

apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: salesforceloginfo--source-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: salesforce-source properties: clientId: "The Consumer Key" clientSecret: "The Consumer Secret" password: "The Password" query: "SELECT Id, Name, Email, Phone FROM Contact" topicName: "ContactTopic" userName: "The Username" sink: uri: "log:info"
Could you please share details on how I can test?
Thanks in advance!!

[oscerd]

Look at kameletBinding in the example repo

[2020testuser]

@oscerd - Thanks! Is this the link you are referring to? If not, could you pls send me the link? sorry. Trying to test salesforce with Kamelet and got struck.

https://github.com/apache/camel-k-examples/tree/main/kamelets

[oscerd]

Yes. There you have examples of binding

[2020testuser]

Thanks! Will check

[2020testuser]

@oscerd - Could you please help me?
I tried using the links above and getting the below error. Thanks!

kamel logs salesforce-loginfo-source-binding

No IntegrationPlatform resource in test-kamelet namespace Integration 'salesforce-loginfo-source-binding' not yet available. Will keep checking ...

[oscerd]

You need to install camel-k operator first

[2020testuser]

First, I installed camel-k using the below cmd. I installed in my Kubernetes cluster which also includes the Knative.
Could you let me know whether I need to install Knative Camel Operator separately?

kubectl apply \n -f "https://github.com/knative/eventing-contrib/releases/\\ndownload/v0.12.2/camel.yaml"

My kamel commands work . Could you clarify pls?
Thanks,

[oscerd]

From what you reported there is no integration platform running in your namespace. Can you please show what you're trying to deploy? And add all the steps you are following? It's not clear.

[oscerd]

By the way to run an example knative is not required.

[2020testuser]

@oscerd - Yes, knative is not requireed. But, in my Kubernetes cluster, knative has been installed for other tasks.

I uninstalled and installed everything.
Now, I get the below result.
Still I don't get any response in Java program when I update salesforce site for contacts.
I'm just using the example in the link and trying to get it working.

kubectl get integrationplatform
NAME PHASE
camel-k

[oscerd]

If you need only kamelets

you should do on a fresh cluster

kamel install -n namespace_name

kubectl apply -f flow-binding.yaml -n namespace_name

[2020testuser]

@oscerd - Yes, I have Kamelet in a different cluster. Deploying the flow-binding.yaml is not giving any error, but, don't the sink part working or doing its task.Is there any way to troubleshoot in kamelet? Thanks!

[oscerd]

where you have the integration running, please do kamel logs <integration_name> and report the content.

[2020testuser]

@oscerd - Thanks!
Could you please let me know how I can get the <intergration_name>? Is there any command available to get the <integration_name>
?

I tried the below commands and get two different results.Is there any way to find where my integration platform is running as I get two different results.

kubectl get integrationplatform NAME PHASE camel-k

kamel logs camel-k
Integration 'camel-k' not yet available. Will keep checking ...

kamel logs camel-k --namespace=my-ns
Unable to retrieve the operator version: Get "https://xxx:6443/api?timeout=32s": dial tcp xxx:6443: i/o timeout
Error: Get "https://xxx:6443/api?timeout=32s": dial tcp xxx:6443: i/o timeout
`
Thanks in advance!