Hi Team,
I am using SFTP Source Connector with below configurations, MOVE cleanup policy is not working for me.Connector is pushing files to topic but not moving the files to done directory.Am I missing something?
Kindly help below are my configurations.
{
"name": "BinaryFileServerSftp_Test2",
"config": {
"connector.class": "io.confluent.connect.sftp.SftpBinaryFileSourceConnector",
"tasks.max": "1",
"value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
"errors.log.enable": "true",
"errors.log.include.messages": "true",
"sftp.host": "XXXXXX",
"sftp.port": "22",
"sftp.username": "XXXXX",
"sftp.password": "XXXXXX",
"kafka.topic": "sftp-server-binary-file-topic-Test2",
"empty.poll.wait.ms": "2000",
"input.path": "/C/Users/data",
"finished.path": "/C/Users/done",
"error.path": "/C/Users/error",
"cleanup.policy": "MOVE",
"input.file.pattern": ".*\\.pdf",
"behavior.on.error": "FAIL",
"file.minimum.age.ms": "1000"
}
}