diff --git a/ftps-source.kamelet.yaml b/ftps-source.kamelet.yaml index 157816dae..38d566dd3 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,8 @@ spec: password: "{{password}}" passiveMode: "{{passiveMode}}" recursive: "{{recursive}}" + idempotent: "{{idempotent}}" steps: - convert-body-to: - type: "java.lang.String" + type: "java.io.InputStream" - to: "kamelet:sink"