如何在kafka中使用基于密钥的身份验证的sftpcsv源连接器?

6za6bjd0  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(318)

我正在尝试使用合流Kafkasftp csv源连接器。在这种情况下,我需要使用私钥对sftp服务器进行身份验证。
我不知道怎么和你一起工作 tls.private.key !
我怎样才能做到这一点?
配置示例:

{
    "tasks.max": "1",
    "connector.class": "io.confluent.connect.sftp.SftpCsvSourceConnector",
    "cleanup.policy": "NONE",
    "behavior.on.error": "IGNORE",
    "input.path": "/csv",
    "error.path": "/error",
    "finished.path": "/finish",
    "input.file.pattern": "sample.csv",
    "sftp.username": "rocky",
    "sftp.host": "192.168.52.69",
    "sftp.port": "22",
    "kafka.topic": "sample-with-cast",
    "csv.first.row.as.header": "true",
    "schema.generation.enabled": "true",
    "transforms": "Cast",
    "transforms.Cast.type": "org.apache.kafka.connect.transforms.Cast$Value",
    "transforms.Cast.spec": "ID:int32,ICCTHR_CaseCrThreshold:float64"
}

注意:我正在发送 Postman 的请求!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题