我正在尝试使用合流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 的请求!
暂无答案!
目前还没有任何答案,快来回答吧!