From 6b0b3a0827a28f42f34810010196631d88aa9d06 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 8 Apr 2021 18:10:21 +0200 Subject: [PATCH 1/2] FTP/FTPS and SFTP: Don't convert body to String, leave as-is or at least try to convert to inputstream - FTPS Related to #121 --- ftps-source.kamelet.yaml | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/ftps-source.kamelet.yaml b/ftps-source.kamelet.yaml index 157816dae..f3188768c 100644 --- a/ftps-source.kamelet.yaml +++ b/ftps-source.kamelet.yaml @@ -53,6 +53,11 @@ spec: description: If a directory, will look for files in all the sub-directories as well. type: boolean default: false + idempotent: + title: Idempotency + description: Skip already processed files. + type: boolean + default: true flow: from: uri: "ftps:{{username}}@{{host}}:{{port}}/{{directoryName}}" @@ -60,7 +65,6 @@ spec: password: "{{password}}" passiveMode: "{{passiveMode}}" recursive: "{{recursive}}" + idempotent: "{{idempotent}}" steps: - - convert-body-to: - type: "java.lang.String" - to: "kamelet:sink" From 06a4a5670addc4a2585ce6b68665fc0321b575bd Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 8 Apr 2021 18:49:51 +0200 Subject: [PATCH 2/2] FTP/FTPS and SFTP: Don't convert body to String, leave as-is or at least convert to InputStream - FTPS Kamelet --- ftps-source.kamelet.yaml | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ftps-source.kamelet.yaml b/ftps-source.kamelet.yaml index f3188768c..38d566dd3 100644 --- a/ftps-source.kamelet.yaml +++ b/ftps-source.kamelet.yaml @@ -67,4 +67,6 @@ spec: recursive: "{{recursive}}" idempotent: "{{idempotent}}" steps: + - convert-body-to: + type: "java.io.InputStream" - to: "kamelet:sink"