-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
False
-
%
-
Todo
-
Undefined
-
1. On OCP 4.6 with CK7, I installed Elasticsearch operator ECK v1.6.0
2. Followed https://www.elastic.co/guide/en/cloud-on-k8s/1.6/k8s-deploy-elasticsearch.html to deploy elasticsearch cluster "quickstart"
3. Installed AMQ streams operator
4. Created kafkaTopic
apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: kafkatopic-to-elastic spec: source: ref: kind: KafkaTopic apiVersion: kafka.strimzi.io/v1beta2 name: 'mytopic' sink: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: elasticsearch-index-sink properties: clusterName: "quickstart" hostAddresses: "quickstart-es-http:9200"
In the log of integration I got follwing error:
[1] 2021-07-13 15:28:32,086 ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main) Failed to start application: org.apache.camel.RuntimeCamelException: org.apache.camel.VetoCamelContextStartException: Failure creating route from template: elasticsearch-index-sink [1] ... [1] Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route sink at: >>> DynamicTo[kamelet-reify:elasticsearch-rest:{{clusterName}}?hostAddresses=RAW({{hostAddresses}})&operation=INDEX&indexName=${exchangeProperty.esIndexName}&enableSSL={{enableSSL}}&user={{user}}&password={{password}}] <<< in route: Route(sink)[From[kamelet://source?routeId=sink] -> [Choice[[... because of Failed to resolve endpoint: kamelet-reify:elasticsearch-rest:{{clusterName}}?hostAddresses=RAW({{hostAddresses}})&operation=INDEX&indexName=${exchangeProperty.esIndexName}&enableSSL={{enableSSL}}&user={{user}}&password=xxxxxx due to: Property with key [user] not found in properties from text: kamelet-reify:elasticsearch-rest:quickstart?hostAddresses=RAW(quickstart-es-http:9200)&operation=INDEX&indexName=${exchangeProperty.esIndexName}&enableSSL=true&user={{user}}&password={{password}}