Тайм-ауты верблюжьего маршрута в конечной точке AWS

Question

У меня есть верблюжий маршрут в kotlin для загрузки файлов из корзины s3, поскольку файлы в корзине не могут быть удалены. Я использую idempotentConsumer, проблема в том, что после нескольких загрузок файлов я начинаю получать: com.amazonaws.http.AmazonHttpClient - Невозможно выполнить выполнить HTTP-запрос: время ожидания подключения. Я обнаружил, что мне нужно закрыть S3ObjectInputStream, но я не уверен, что я делаю неправильно или где мне это закрыть.

            from("aws-s3://$bucketName?accessKey=RAW($s3AccessKey)&secretKey=RAW($s3SecretKey)&region=$s3Region&deleteAfterRead=$deleteAfterRead&prefix=$prefix")
                    .idempotentConsumer(header("CamelAwsS3Key"), FileIdempotentRepository.fileIdempotentRepository(File(transporter.cacheRepo!!), 250, 512000))
                    .setHeader("fileName", simple("header.CamelAwsS3Key"))
                    .process {
                       it.`in`.getBody(S3ObjectInputStream::class.java).close()
                                              }
                    .to("file:$mutualPath/?fileName=\${header.fileName}")
                    .log("File name set to \${header.CamelAwsS3Key}")