diff --git a/sftp-source.kamelet.yaml b/sftp-source.kamelet.yaml
index 0f9293125..a7d376f43 100644
--- a/sftp-source.kamelet.yaml
+++ b/sftp-source.kamelet.yaml
@@ -67,4 +67,6 @@ spec:
         recursive: "{{recursive}}"
         idempotent: "{{idempotent}}"
       steps:
+      - convert-body-to:
+          type: "java.io.InputStream"
       - to: "kamelet:sink"