Solr Sink Kamelet

docs/modules/ROOT/nav.adoc

@@ -121,6 +121,7 @@
 * xref:ROOT:sftp-source.adoc[image:kamelets/sftp-source.svg[] SFTP Source]
 * xref:ROOT:slack-sink.adoc[image:kamelets/slack-sink.svg[] Slack Sink]
 * xref:ROOT:slack-source.adoc[image:kamelets/slack-source.svg[] Slack Source]
+* xref:ROOT:solr-sink.adoc[image:kamelets/solr-sink.svg[] Solr Sink]
 * xref:ROOT:sqlserver-sink.adoc[image:kamelets/sqlserver-sink.svg[] Microsoft SQL Server Sink]
 * xref:ROOT:sqlserver-source.adoc[image:kamelets/sqlserver-source.svg[] Microsoft SQL Server Source]
 * xref:ROOT:ssh-source.adoc[image:kamelets/ssh-source.svg[] SSH Source]

docs/modules/ROOT/pages/solr-sink.adoc

@@ -0,0 +1,152 @@
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT
+
+= image:kamelets/solr-sink.svg[] Solr Sink
+
+*Provided by: "Apache Software Foundation"*
+
+*Support Level for this Kamelet is: "Preview"*
+
+Send documents to Solr Collection.
+
+== Configuration Options
+
+The following table summarizes the configuration options available for the `solr-sink` Kamelet:
+[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
+|===
+| Property| Name| Description| Type| Default| Example
+| *collection {empty}* *| Collection| Solr Collection name| string| | 
+| *servers {empty}* *| Servers| Comma separated list of Solr Servers and ports| string| | 
+| autocommit| Autocommit| If autocommit should be enabled or not| boolean| `false`| 
+|===
+
+NOTE: Fields marked with an asterisk ({empty}*) are mandatory.
+
+
+== Dependencies
+
+At runtime, the `solr-sink` Kamelet relies upon the presence of the following dependencies:
+
+- camel:solr
+- camel:core
+- camel:jackson
+- camel:kamelet 
+
+== Usage
+
+This section describes how you can use the `solr-sink`.
+
+=== Knative Sink
+
+You can use the `solr-sink` Kamelet as a Knative sink by binding it to a Knative object.
+
+.solr-sink-binding.yaml
+[source,yaml]
+----
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+  name: solr-sink-binding
+spec:
+  source:
+    ref:
+      kind: Channel
+      apiVersion: messaging.knative.dev/v1
+      name: mychannel
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: solr-sink
+    properties:
+      collection: "The Collection"
+      servers: "The Servers"
+
+----
+
+==== *Prerequisite*
+
+You have xref:{camel-k-version}@camel-k::installation/installation.adoc[Camel K installed] on the cluster.
+
+==== *Procedure for using the cluster CLI*
+
+. Save the `solr-sink-binding.yaml` file to your local drive, and then edit it as needed for your configuration.
+
+. Run the sink by using the following command:
++
+[source,shell]
+----
+kubectl apply -f solr-sink-binding.yaml
+----
+
+==== *Procedure for using the Kamel CLI*
+
+Configure and run the sink by using the following command:
+
+[source,shell]
+----
+kamel bind channel:mychannel solr-sink -p "sink.collection=The Collection" -p "sink.servers=The Servers"
+----
+
+This command creates the KameletBinding in the current namespace on the cluster.
+
+=== Kafka Sink
+
+You can use the `solr-sink` Kamelet as a Kafka sink by binding it to a Kafka topic.
+
+.solr-sink-binding.yaml
+[source,yaml]
+----
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+  name: solr-sink-binding
+spec:
+  source:
+    ref:
+      kind: KafkaTopic
+      apiVersion: kafka.strimzi.io/v1beta1
+      name: my-topic
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: solr-sink
+    properties:
+      collection: "The Collection"
+      servers: "The Servers"
+
+----
+
+==== *Prerequisites*
+
+* You've installed https://strimzi.io/[Strimzi].
+* You've created a topic named `my-topic` in the current namespace.
+* You have xref:{camel-k-version}@camel-k::installation/installation.adoc[Camel K installed] on the cluster.
+
+==== *Procedure for using the cluster CLI*
+
+. Save the `solr-sink-binding.yaml` file to your local drive, and then edit it as needed for your configuration.
+
+. Run the sink by using the following command:
++
+[source,shell]
+----
+kubectl apply -f solr-sink-binding.yaml
+----
+
+==== *Procedure for using the Kamel CLI*
+
+Configure and run the sink by using the following command:
+
+[source,shell]
+----
+kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic solr-sink -p "sink.collection=The Collection" -p "sink.servers=The Servers"
+----
+
+This command creates the KameletBinding in the current namespace on the cluster.
+
+== Kamelet source file
+
+https://github.com/apache/camel-kamelets/blob/main/kamelets/solr-sink.kamelet.yaml
+
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT

kamelets/solr-sink.kamelet.yaml

@@ -0,0 +1,77 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+  name: solr-sink
+  annotations:
+    camel.apache.org/kamelet.support.level: "Preview"
+    camel.apache.org/catalog.version: "main-SNAPSHOT"
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIGhlaWdodD0iODAwIiB3aWR0aD0iMTIwMCIgdmlld0JveD0iLTQwLjYwMDk1IC0zNC4yMTc3NSAzNTEuODc0OSAyMDUuMzA2NSI+PGRlZnM+PGNsaXBQYXRoIGlkPSJhIiBjbGlwUGF0aFVuaXRzPSJ1c2VyU3BhY2VPblVzZSI+PHBhdGggZD0iTTAgMTAyLjY1NGgyMDMuMDA1VjBIMHoiLz48L2NsaXBQYXRoPjwvZGVmcz48ZyBjbGlwLXBhdGg9InVybCgjYSkiIHRyYW5zZm9ybT0ibWF0cml4KDEuMzMzMzMgMCAwIC0xLjMzMzMzIDAgMTM2Ljg3MSkiPjxwYXRoIGQ9Ik00MC43NiAzMS43NjNjLTIuMzQ0IDEuMjQ4LTQuOTk0IDIuMTI3LTcuODc0IDIuNjEzYTUxLjcwNyA1MS43MDcgMCAwMS04LjU1NC43MTdjLTIuMzI3IDAtNC42ODEuMjAxLTYuOTk4LjU5Ny0yLjI1Ni4zODQtNC4zIDEuMDkyLTYuMDc2IDIuMTA0LTEuNzMuOTg0LTMuMTYgMi4zNjEtNC4yNTIgNC4wOTUtMS4wNzggMS43MDYtMS42MjQgMy45NjgtMS42MjQgNi42OTcuMDUyIDIuNDEuNjEyIDQuNDcyIDEuNjY2IDYuMTNhMTIuNTUyIDEyLjU1MiAwIDAwNC4xNDcgNC4wNjZjMS43MjYgMS4wNDEgMy43MTggMS44MDYgNS45MiAyLjI3NCAzLjc1Mi43OTYgNy43MTQuOTQ1IDExLjc1LjM4MmEyMi40MTYgMjIuNDE2IDAgMDA0LjYzLTEuMTY4IDE2LjY5MSAxNi42OTEgMCAwMDQuMTA2LTIuMjE3IDE0LjA3IDE0LjA3IDAgMDAzLjI0Ni0zLjQxbC41MTQtLjc1NiAzLjc4OCAxLjU5NC0uODA0IDEuMTM1YTI1LjAzIDI1LjAzIDAgMDEtMy4zOTUgMy45IDE3LjI2NiAxNy4yNjYgMCAwMS00LjM1NiAyLjkwNWMtMS42MjMuNzY1LTMuNDggMS4zNTQtNS41MjIgMS43NTEtMi4wMjEuMzkyLTQuMzc3LjU5LTcuMDAzLjU5YTM2LjMzIDM2LjMzIDAgMDEtNy43My0uODU4Yy0yLjY1LS41OC01LjEwNi0xLjUzOC03LjMwMS0yLjg0OWExNi41OTEgMTYuNTkxIDAgMDEtNS40OTMtNS4zMDZjLTEuNDI1LTIuMjE5LTIuMTUtNC45NTctMi4xNS04LjEzOSAwLTMuMzQuNjcyLTYuMTgzIDEuOTk0LTguNDQ5IDEuMzE0LTIuMjUyIDMuMDc2LTQuMDc3IDUuMjM3LTUuNDIzIDIuMTE2LTEuMzIgNC41ODUtMi4yNjkgNy4zMzgtMi44MmE0Mi43NjcgNDIuNzY3IDAgMDE4LjM2OC0uODFjMi4yNzYgMCA0LjY4Ni0uMTczIDcuMTY0LS41MTYgMi40MS0uMzMzIDQuNjU1LTEuMDA1IDYuNjY5LTEuOTk3IDEuOTYyLS45NjkgMy41OTctMi4zMTYgNC44NTctNC4wMDUgMS4yMTktMS42MzUgMS44MzgtMy44NDMgMS44MzgtNi41NjIgMC0yLjQ0Mi0uNTk2LTQuNTI0LTEuNzctNi4xOTMtMS4yMTEtMS43MjQtMi43ODUtMy4xNDctNC42NzgtNC4yMjktMS45MzQtMS4xMDUtNC4xMjMtMS45MTktNi41MS0yLjQxOGEzNC45MDMgMzQuOTAzIDAgMDAtNy4xMzItLjc2NWMtMy44NzMgMC03LjcuNzQtMTEuMzc0IDIuMmEyNy4xOCAyNy4xOCAwIDAwLTkuNjQgNi40ODJsLS43MzUuNzY1TDAgMTEuMjUybC44NDgtLjg0OGMyLjcwMy0yLjcwNSA2LjA2LTUuMDYgOS45NzUtNy4wMDJDMTQuNzg2IDEuNDM1IDE5LjQ3OS40MzggMjQuNzcuNDM4YzIuNTE2IDAgNS4xODYuMjg4IDcuOTM4Ljg1NSAyLjc5LjU3NyA1LjQwOCAxLjU2MiA3Ljc4IDIuOTMxIDIuNDEgMS4zOSA0LjQxNSAzLjIxIDUuOTYyIDUuNDA2IDEuNTg5IDIuMjU3IDIuMzk1IDUuMDgxIDIuMzk1IDguMzk4IDAgMy4zNjEtLjc1NSA2LjIwNy0yLjI0NSA4LjQ2LTEuNDcxIDIuMjItMy40MzUgMy45OTUtNS44NCA1LjI3NU03Ni4zOSAzLjk4NWMtMi43MzIgMC01LjIzLjU2NC03LjQyNiAxLjY3NmExOS4xNDggMTkuMTQ4IDAgMDAtNS44NCA0LjU1NmMtMS42NTggMS45MDctMi45NzYgNC4xMzctMy45MTYgNi42M2EyNC44NTMgMjQuODUzIDAgMDAtMS41OTMgNy43NTNjMCAyLjQzLjQ1IDQuOTExIDEuMzM2IDcuMzc4YTIxLjY0OCAyMS42NDggMCAwMDMuODMzIDYuNjY2IDIwLjQxNCAyMC40MTQgMCAwMDUuOTg0IDQuODJjMi4yNzggMS4yMiA0Ljg0MiAxLjg0IDcuNjIyIDEuODQgMi42MTQgMCA1LjA4My0uNTggNy4zMzgtMS43MmEyMC4wMDMgMjAuMDAzIDAgMDA1Ljk3OC00LjYwN2MxLjY4NS0xLjkwOCAzLjAzLTQuMTM5IDQuMDAyLTYuNjMyYTIxLjMxNSAyMS4zMTUgMCAwMDEuNDU3LTcuNzQ1YzAtMi40MjYtLjQ1LTQuOTA5LTEuMzM1LTcuMzc3YTIxLjY0IDIxLjY0IDAgMDAtMy44MzQtNi42NjggMTkuODEzIDE5LjgxMyAwIDAwLTUuOTc1LTQuNzdjLTIuMjgtMS4xOTUtNC44NDYtMS44LTcuNjMxLTEuOG0xNi41NzcgMzcuMzc3Yy0xLjk4MiAyLjMxNi00LjM5MSA0LjIzMi03LjE2MiA1LjY5NC0yLjgxIDEuNDgyLTUuOTc3IDIuMjMyLTkuNDE1IDIuMjMyLTMuMTMyIDAtNi4xMjQtLjY3LTguODkzLTEuOTkzYTIzLjIwMiAyMy4yMDIgMCAwMS03LjIyNS01LjM4NGMtMi4wMzctMi4yNDktMy42Ny00Ljg5OC00Ljg1NC03Ljg3M0EyNS40MDEgMjUuNDAxIDAgMDE1My42MyAyNC42YzAtMy4xMDMuNTU1LTYuMTQgMS42NS05LjAyN2EyNS43OTUgMjUuNzk1IDAgMDE0LjYyNS03Ljc4NCAyMy4zODggMjMuMzg4IDAgMDE3LjE3NS01LjU2NkM2OS44NzcuODEgNzMuMDAzLjA2MSA3Ni4zNyAwaC4wNDJjMy4xODYuMDYxIDYuMjAzLjc3OCA4Ljk2NyAyLjEyOGEyMy43NjMgMjMuNzYzIDAgMDE3LjIxNyA1LjQyNGMyLjAzNyAyLjI1IDMuNjU2IDQuODcgNC44MSA3Ljc4N0EyNS4wNTcgMjUuMDU3IDAgMDE5OS4xNSAyNC42YzAgMi45MTctLjU0IDUuODktMS42IDguODM1YTI1LjQ0MiAyNS40NDIgMCAwMS00LjU4MyA3LjkyN00xMTkuNzgzIDUuMDljLS42Ny0uMTY2LTEuMjYtLjI5My0xLjc1Mi0uMzc1YTczLjE5MiA3My4xOTIgMCAwMC0xLjY4NS0uMjYgMTEuNzE3IDExLjcxNyAwIDAwLTEuNjM4LS4xMmMtMS4zMzcgMC0yLjMyLjQ0NC0zLjAxIDEuMzU2LS43NiAxLjAwNC0xLjEzIDItMS4xMyAzLjA0OXY1OC4zMzdoLTMuOTg2VjguNzRjMC0yLjE5LjY5MS00LjEyNiAyLjA1NS01Ljc1NCAxLjQxMy0xLjY5MSAzLjQyNi0yLjU0NyA1Ljk4My0yLjU0N2EyMCAyMCAwIDAxMi4zNjcuMTM5Yy43NDIuMDg5IDEuNDEuMTc4IDIuMDA2LjI2Ny42MS4wOTIgMS4zMTYuMjMgMi4xLjQxbDEuMzUxLjMxMi0xLjc3NCAzLjc0NnptMTcuMTk1IDQwLjE4M2MtMi4wNzMtMS40NTctMy45MDQtMy4zMDctNS40NzEtNS41MjJ2OC44MzZoLTMuOTg1Vi44NzdoMy45ODVWMzAuNThhMjQuMTYgMjQuMTYgMCAwMDIuMjYgNS40MjYgMTcuMjU0IDE3LjI1NCAwIDAwMy41MzkgNC4zNjIgMTYuOTE1IDE2LjkxNSAwIDAwNC44MSAyLjk1OGMxLjc5OS43MzYgMy44MjggMS4xNjYgNi4wMzIgMS4yNzdsMS4wNi4wNTN2My45MzFoLTEuMTE2Yy00LjI0NyAwLTcuOTg2LTEuMTE1LTExLjExNC0zLjMxNCIgZmlsbD0iIzI0MWYyYiIvPjxwYXRoIGQ9Ik0xOTMuOTExIDkyLjA0MWwtMzMtMzUuNjc3IDQxLjQ3MyAxOS4xMzRhMzMuNDggMzMuNDggMCAwMS04LjQ3MiAxNi41NDNtLTI0LjQ4NSAxMC42MTNjLTQuNTcyIDAtOC45MjgtLjkxNy0xMi45LTIuNTcybC00LjQyOC0zNy4zMTQgMjIuMTI3IDM5LjUzOWEzMy43NTYgMzMuNzU2IDAgMDEtNC44LjM0N20zMy4yODctMjkuMjExTDE2My40MTUgNTEuNDVsMzYuODcgNC4zNzVhMzMuNDU2IDMzLjQ1NiAwIDAxMi40MjggMTcuNjE3bS0xNC40ODgtMzIuMTk0YTMzLjc0OCAzMy43NDggMCAwMTEwLjYxMiAxMS42MTlsLTM0LjU2LTYuODYzem0tMTEuOTc1IDYwLjcxMWwtMTkuMjM4LTQxLjY5NSAzNS42ODUgMzMuMDA2Yy00LjQ3NSA0LjMwNS0xMC4xMzUgNy4zODYtMTYuNDQ4IDguNjg5bS00LjAxNi02Ni4zMzdhMzMuMzcgMzMuMzcgMCAwMTEwLjU0IDIuNjM4bC0xOS4zNTggMi4yOTd6bS0zMy40MTQgNDcuMjU3YTMzLjM2NSAzMy4zNjUgMCAwMS0yLjgzLTEwLjc5Mmw1LjIxNi05LjMyem0xNC43OTggMTUuODIyYTMzLjczNiAzMy43MzYgMCAwMS0xMS44MzItMTAuNTY3bDQuODY3LTI0LjUwNHoiIGZpbGw9IiNkYTM1MjIiLz48L2c+PC9zdmc+"
+    camel.apache.org/provider: "Apache Software Foundation"
+    camel.apache.org/kamelet.group: "Solr"
+  labels:
+    camel.apache.org/kamelet.type: "sink"
+spec:
+  definition:
+    title: "Solr Sink"
+    description: |-
+      Send documents to Solr Collection.
+    required:
+      - servers
+      - collection
+    type: object
+    properties:
+      collection:
+        title: Collection
+        description: Solr Collection name
+        type: string
+      servers:
+        title: Servers
+        description: Comma separated list of Solr Servers and ports
+        type: string
+      autocommit:
+        title: Autocommit 
+        description: If autocommit should be enabled or not
+        type: boolean
+        default: false
+        x-descriptors:
+        - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+  types:
+    in:
+      mediaType: application/json
+  dependencies:
+  - "camel:solr"
+  - "camel:core"
+  - "camel:jackson"
+  - "camel:kamelet"
+  flow:
+    from:
+      uri: "kamelet:source"
+      steps:
+      - set-header:
+          name: "SolrOperation"
+          constant: "INSERT"
+      - unmarshal:
+          json:
+            library: Jackson
+      - remove-header:
+          name: "content-type"
+      - to:
+          uri: "solr:{{servers}}/solr/{{collection}}"
+          parameters:
+            autocommit: "{{autocommit}}"