Generated sources regen

library/camel-kamelets-catalog/src/main/resources/kamelets/elasticsearch-index-sink.kamelet.yaml

@@ -29,9 +29,10 @@ spec:
 
       If the *indexId* parameter is not set and the source of the kamelet binding is a Kafka broker, it will take the kafka topic, partition and offset of the
       element to generate an automatic ID that warrantees that this element is processed only once.
+
+      If the *indexName* parameter is not set and the source of the kamelet binding is a Kafka broker, it will take the kafka topic as the indexName.
     required:
       - clusterName
-      - indexName
       - hostAddresses
     type: object
     properties:
@@ -60,6 +61,7 @@ spec:
         description: The name of the index to act against.
         type: string
         example: data
+        default: 'NONE'
       clusterName:
         title: ElasticSearch Cluster Name
         description: Name of the cluster.
@@ -69,7 +71,7 @@ spec:
         title: Index ID
         description: None
         type: string
-        default: "NONE"
+        default: 'NONE'
   types:
     out:
       mediaType: application/json
@@ -97,14 +99,18 @@ spec:
                   - set-header:
                       name: "indexId"
                       simple: "{{indexId}}"
-        - to:
-            uri: "kamelet-reify:elasticsearch-rest:{{clusterName}}"
-            parameters:
-              operation: "INDEX"
-              indexName: "{{indexName}}"
-              hostAddresses: "{{hostAddresses}}"
-              enableSSL: "{{enableSSL}}"
-              user: "{{user}}"
-              password: "{{password}}"
+        - choice:
+            when:
+              - simple: "'{{indexName}}' == 'NONE'"
+                steps:
+                  - set-property:
+                      name: esIndexName
+                      simple: "${header[kafka.TOPIC]}"
+            otherwise:
+              steps:
+                - set-property:
+                    name: esIndexName
+                    simple: "{{indexName}}"
+        - to-d: "kamelet-reify:elasticsearch-rest:{{clusterName}}?hostAddresses=RAW({{hostAddresses}})&operation=INDEX&indexName=${exchangeProperty.esIndexName}&enableSSL={{enableSSL}}&user={{user}}&password={{password}}"
         - marshal:
             json: { }