You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/12/14 06:59:25 UTC
[camel-kamelets] branch main updated: Regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new e01a263 Regen
e01a263 is described below
commit e01a26311dc7dadedd4caaccb1a5ea3bd1ce133f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Dec 14 07:58:47 2021 +0100
Regen
---
.../resources/kamelets/pulsar-sink.kamelet.yaml | 171 +++++++++++++++++++++
1 file changed, 171 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/pulsar-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/pulsar-sink.kamelet.yaml
new file mode 100644
index 0000000..77016c7
--- /dev/null
+++ b/library/camel-kamelets/src/main/resources/kamelets/pulsar-sink.kamelet.yaml
@@ -0,0 +1,171 @@
+# ---------------------------------------------------------------------------
+# 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: pulsar-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,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcKICAgdmlld0JveD0iMCAwIDYwLjk3Mzk5OSA0My4wOSIKICAgdmVyc2lvbj0iMS4xIgogICBpZD0ic3ZnMjQiCiAgIHNvZGlwb2RpOmRvY25hbWU9InB1bHNhci1sb2dvLnN2ZyIKICAgd2lkdGg9IjYwLjk3Mzk5OSIKICAgaGVpZ2h0PSI0My4wOSIKICAgaW5rc2NhcGU6dmVyc2lvbj0iMS4xLjEgKDNiZjVhZTBkMjUsIDIwMjEtMDktMjApIgogICB4bWxuczppbmtzY2FwZT0iaHR0cDovL3d3dy5pbmtzY2FwZS5vcmcvbmFtZXNwYWNlcy9pbmtzY2FwZSIKICAgeG [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "Pulsar"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ dependencies:
+ - "camel:pulsar"
+ - "camel:kamelet"
+ - "camel:core"
+ definition:
+ title: "Pulsar Sink"
+ description: "Send documents to Pulsar."
+ required:
+ - topicType
+ - topic
+ - namespaceName
+ - tenant
+ - serviceUrl
+ properties:
+ topic:
+ title: Topic Name
+ description: The topic name or regexp
+ type: string
+ tenant:
+ title: Tenant Name
+ description: The Tenant Name
+ type: string
+ topicType:
+ title: Topic Type
+ description: "The topic type. Possible values are: persistent or non-persistent"
+ type: string
+ namespaceName:
+ title: Pulsar Namespace Name
+ description: The Pulsar Namespace Name
+ type: string
+ serviceUrl:
+ title: Service URL
+ description: The Pulsar Service URL to point while creating the client from URI.
+ type: string
+ authenticationClass:
+ title: Authentication Class
+ description: The Authentication FQCN to be used while creating the client from URI.
+ type: string
+ authenticationParams:
+ title: Authentication Params
+ description: The Authentication Parameters to be used while creating the client from URI.
+ type: string
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:text'
+ batchingEnabled:
+ title: Enable Batching
+ description: Control whether automatic batching of messages is enabled for the producer.
+ type: boolean
+ default: true
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ batchingMaxMessages:
+ title: Batching Maximum Messages
+ description: "The maximum size to batch messages."
+ type: int
+ default: 1000
+ batchingMaxPublishDelayMicros:
+ title: Batching Maximum Publish Delay in Microsecond
+ description: "The maximum time period within which the messages sent will be batched if batchingEnabled is true."
+ type: long
+ default: 1000
+ blockIfQueueFull:
+ title: Block If Queue Full
+ description: "Whether to block the producing thread if pending messages queue is full or to throw a ProducerQueueIsFullError."
+ type: boolean
+ default: false
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ compressionType:
+ title: Compression Type
+ description: "Compression type to use. Possible values are: NONE, LZ4, ZLIB, ZSTD, SNAPPY"
+ type: string
+ default: "NONE"
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:select:NONE'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:LZ4'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:ZLIB'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:ZSTD'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:SNAPPY'
+ initialSequenceId:
+ title: Initial SequenceId
+ description: "The first message published will have a sequence Id of initialSequenceId 1."
+ type: long
+ default: -1
+ lazyStartProducer:
+ title: Number Of Consumer Threads
+ description: "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the [...]
+ type: boolean
+ default: false
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ maxPendingMessages:
+ title: Maximum Pending Messages
+ description: "Size of the pending massages queue. When the queue is full, by default, any further sends will fail unless blockIfQueueFull=true."
+ type: int
+ default: 1000
+ maxPendingMessagesAcrossPartitions:
+ title: Maximum Pending Messages Across Partitions
+ description: "The maximum number of pending messages for partitioned topics. The maxPendingMessages value will be reduced if (number of partitions maxPendingMessages) exceeds this value. Partitioned topics have a pending message queue for each partition."
+ type: int
+ default: 50000
+ messageRoutingMode:
+ title: Message Routing Mode
+ description: "Message Routing Mode to use. Possible values are SinglePartition, RoundRobinPartition, CustomPartition"
+ type: string
+ default: "RoundRobinPartition"
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:select:SinglePartition'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:RoundRobinPartition'
+ - 'urn:alm:descriptor:com.tectonic.ui:select:CustomPartition'
+ producerName:
+ title: Producer Name
+ description: "Name of the producer. If unset, lets Pulsar select a unique identifier."
+ type: string
+ sendTimeoutMs:
+ title: Send Timeout in Milliseconds
+ description: "Send timeout in milliseconds."
+ type: int
+ default: 30000
+ type: object
+ flow:
+ from:
+ uri: kamelet:source
+ steps:
+ - to:
+ uri: pulsar:{{topicType}}/{{tenant}}/{{namespaceName}}/{{topic}}
+ parameters:
+ serviceUrl: "{{serviceUrl}}"
+ authenticationClass: "{{?authenticationClass}}"
+ authenticationParams: "{{?authenticationParams}}"
+ batchingEnabled: "{{?batchingEnabled}}"
+ batchingMaxMessages: "{{?batchingMaxMessages}}"
+ batchingMaxPublishDelayMicros: "{{?batchingMaxPublishDelayMicros}}"
+ blockIfQueueFull: "{{?blockIfQueueFull}}"
+ compressionType: "{{?compressionType}}"
+ initialSequenceId: "{{?initialSequenceId}}"
+ lazyStartProducer: "{{?lazyStartProducer}}"
+ maxPendingMessages: "{{?maxPendingMessages}}"
+ maxPendingMessagesAcrossPartitions: "{{?maxPendingMessagesAcrossPartitions}}"
+ messageRoutingMode: "{{?messageRoutingMode}}"
+ producerName: "{{?producerName}}"
+ sendTimeoutMs: "{{?sendTimeoutMs}}"