You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by vishnu murali <vi...@gmail.com> on 2020/05/18 13:28:14 UTC

SFTP Connector

Hey Guys,

Now i am trying to implement SFTP connector by using this configurations.

i am using windows system.

so i am having doubts like how to set a path?

i tried to set like this in *config *as well as */mnt/c/users/vmuralidharan*

but it doesn't work.


so what i need to do ?

{
    "name": "CsvSFTP11",
    "config": {
        "tasks.max": "1",
        "connector.class":
"io.confluent.connect.sftp.SftpCsvSourceConnector",
        "cleanup.policy": "NONE",
        "behavior.on.error": "IGNORE",
        "input.path": " C:\\Users\\vmuralidharan",
        "error.path": "C:\\Users\\vmuralidharan\\Desktop\\error",
        "finished.path": "C:\\Users\\vmuralidharan\\Desktop\\finished",
        "input.file.pattern": "purchase.csv",
        "kafka.topic": "sftp-testing-topic",
        "csv.first.row.as.header": "true",
        "schema.generation.enabled": "false"
    }
}

How to get solution for this?

SFTP Connector

Posted by vishnu murali <vi...@gmail.com>.

Hey Guys,

Now i am trying to implement SFTP connector by using this configurations.

i am using windows system.

so i am having doubts like how to set a path?

i tried to set like this in *config *as well as */mnt/c/users/vmuralidharan*

but it doesn't work.


so what i need to do ?

{
    "name": "CsvSFTP11",
    "config": {
        "tasks.max": "1",
        "connector.class":
"io.confluent.connect.sftp.SftpCsvSourceConnector",
        "cleanup.policy": "NONE",
        "behavior.on.error": "IGNORE",
        "input.path": " C:\\Users\\vmuralidharan",
        "error.path": "C:\\Users\\vmuralidharan\\Desktop\\error",
        "finished.path": "C:\\Users\\vmuralidharan\\Desktop\\finished",
        "input.file.pattern": "purchase.csv",
        "kafka.topic": "sftp-testing-topic",
        "csv.first.row.as.header": "true",
        "schema.generation.enabled": "false"
    }
}

How to get solution for this?