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
commit 6799eed1d3b3550b32d2db5f04d0c6dd749b8633 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Jan 30 11:29:32 2024 +0100 Support Kafka Batch as Kamelet source - Kafka Batch Commit action Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../kafka-batch-manual-commit-action.kamelet.yaml | 42 ++++++++++++++++++++++ 1 file changed, 42 insertions(+) diff --git a/kamelets/kafka-batch-manual-commit-action.kamelet.yaml b/kamelets/kafka-batch-manual-commit-action.kamelet.yaml new file mode 100644 index 00000000..12827e06 --- /dev/null +++ b/kamelets/kafka-batch-manual-commit-action.kamelet.yaml @@ -0,0 +1,42 @@ +# --------------------------------------------------------------------------- +# 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/v1 +kind: Kamelet +metadata: + name: kafka-batch-manual-commit-action + labels: + camel.apache.org/kamelet.type: "action" + annotations: + camel.apache.org/kamelet.support.level: "Stable" + camel.apache.org/catalog.version: "4.4.0-SNAPSHOT" + camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcKICAgeG1sbnM6ZGM9Imh0dHA6Ly9wdXJsLm9yZy9kYy9lbGVtZW50cy8xLjEvIgogICB4bWxuczpjYz0iaHR0cDovL2NyZWF0aXZlY29tbW9ucy5vcmcvbnMjIgogICB4bWxuczpyZGY9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkvMDIvMjItcmRmLXN5bnRheC1ucyMiCiAgIHhtbG5zOnN2Zz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciCiAgIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM6c29kaXBvZGk9Imh0dHA6Ly9zb2RpcG [...] + camel.apache.org/provider: "Apache Software Foundation" + camel.apache.org/kamelet.group: "Actions" + camel.apache.org/kamelet.namespace: "Kafka" +spec: + definition: + title: "Kafka Batch Manual Commit Action" + description: "Manually commit Kafka Batch Offset" + type: object + dependencies: + - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT" + - "camel:kamelet" + template: + from: + uri: kamelet:source + steps: + - bean: "org.apache.camel.kamelets.utils.transform.kafka.BatchManualCommit"