Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-16998

KameletBinding from KafkaTopic to elasticsearch-index-sink seems to require user parameter

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • Camel-K-GA
    • None
    • Camel-K
    • None
    • False
    • False
    • % %
    • Todo
    • Undefined

    Description

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

       

      Attachments

        Activity

          People

            acosenti Andrea Cosentino
            lfabriko@redhat.com Lucie Krejcirova
            Andrea Cosentino, Maria Arias de Reyna Dominguez, Michael Cada
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: