You need to enable JavaScript to run this app.
最新活动
产品
解决方案
定价
生态与合作
支持与服务
开发者
了解我们

ConfluentSftpsinkconnector返回“FailedtoopennewSFTPchannelwithexistingsession”。

此问题可能由于使用了错误的配置参数导致sftp会话未能正确关闭。 可以通过以下方式解决此问题:

  1. 确保传递给 Confluent Sftp sink 连接器的配置参数正确。比如,确保传递了正确的用户名、密码和ssh端口。可参考下面的示例代码:
name=sftp-sink
connector.class=io.confluent.connect.sftp.SftpSinkConnector
tasks.max=1
topics=some-topic
input.path=/input
error.path=/error
finished.path=/finished
sftp.username=someuser
sftp.password=somepassword
sftp.host=somehost
sftp.port=22
sftp.cleanup.policy=NONE
  1. 确保 sftp 会话正确关闭。要确保会话正确关闭,请确保正确设置以下参数:
sftp.max.open.channels=1
sftp.max.concurrent.connections=1
sftp.max.request.queue.size=1

这些参数限制了sftp连接器可以打开的最大信道数、并发连接数和请求队列大小。确保这些参数设置正确,以避免未能正确关闭会话。

  1. 如果仍然无法解决问题,则可能需要检查 sftp 服务器的配置,以确保它支持 Confluent Sftp 连接器的要求。

  2. 如果问题依然存在,请联系 Confluent 支持。

本文内容通过AI工具匹配关键字智能整合而成,仅供参考,火山引擎不对内容的真实、准确或完整作任何形式的承诺。如有任何问题或意见,您可以通过联系service@volcengine.com进行反馈,火山引擎收到您的反馈后将及时答复和处理。
展开更多
面向开发者的云福利中心,ECS 60元/年,域名1元起,助力开发者快速在云上构建可靠应用

社区干货

「火山引擎」数据中台产品双月刊 VOL.05

优化 OpenAPI 参数和文档体验,便于客户更好地进行调用- 优化升级 Go driver,优化客户使用体验并提供功能更新**【新增 ByteHouse 企业版功能】**- 私有化版本全面支持监控告警:飞书告警,邮件告警等- ... HBase和ByteHouse Connector,支持MySQL Sink,优化多个配置,达到开箱即用;支持avro,csv,debezium-json和avro-confluent等格式;Presto、Trino优化进入客户端方式。- 新增软件栈 2.2.0:HBase集群中集成Knox组件用于...

「火山引擎」数智平台 VeDI 数据中台产品双月刊 VOL.05

优化 OpenAPI 参数和文档体验,便于客户更好地进行调用- 优化升级 Go driver,优化客户使用体验并提供功能更新 **【新增 ByteHouse 企业版功能】**- 私有化版本全面支持监控告警:飞书告警,... HBase和ByteHouse Connector,支持MySQL Sink,优化多个配置,达到开箱即用;支持avro,csv,debezium-json和avro-confluent等格式;Presto、Trino优化进入客户端方式。- 新增软件栈 2.2.0:HBase集群中集成Knox组件用...

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

ConfluentSftpsinkconnector返回“FailedtoopennewSFTPchannelwithexistingsession”。 -优选内容

「火山引擎」数据中台产品双月刊 VOL.05
优化 OpenAPI 参数和文档体验,便于客户更好地进行调用- 优化升级 Go driver,优化客户使用体验并提供功能更新**【新增 ByteHouse 企业版功能】**- 私有化版本全面支持监控告警:飞书告警,邮件告警等- ... HBase和ByteHouse Connector,支持MySQL Sink,优化多个配置,达到开箱即用;支持avro,csv,debezium-json和avro-confluent等格式;Presto、Trino优化进入客户端方式。- 新增软件栈 2.2.0:HBase集群中集成Knox组件用于...
EMR-3.2.1 版本说明
debezium-json和avro-confluent等格式; 【组件】Doris版本升级至1.2.1; 【组件】修复Presto写入TOS的潜在问题; 【集群】Kafka集群高可用优化,修复潜在的内置组件出现单点问题导致集群操作异常问题; 【组件】Flink升级至1.16.0,引入StarRocks、Doris、HBase和ByteHouse Connector,支持MySQL Sink,优化多个配置,达到开箱即用; 【组件】Hive适配CFS, 支持外部表方式访问数据; 【组件】presto-cli和trino-cli支持非明文方式输入...
「火山引擎」数智平台 VeDI 数据中台产品双月刊 VOL.05
优化 OpenAPI 参数和文档体验,便于客户更好地进行调用- 优化升级 Go driver,优化客户使用体验并提供功能更新 **【新增 ByteHouse 企业版功能】**- 私有化版本全面支持监控告警:飞书告警,... HBase和ByteHouse Connector,支持MySQL Sink,优化多个配置,达到开箱即用;支持avro,csv,debezium-json和avro-confluent等格式;Presto、Trino优化进入客户端方式。- 新增软件栈 2.2.0:HBase集群中集成Knox组件用...
CreateCloudConnectorAuthorizationRules
调用CreateCloudConnectorAuthorizationRules为云连接器实例创建授权规则。 请求参数名称 类型 是否必选 示例值 描述 Action String 是 CreateCloudConnectorAuthorizationRules 要执行的操作,取值:CreateCloudCon... 若不传入ClientToken,则此次API调用不进行幂等校验。 返回数据名称 类型 示例值 描述 RequestId String 0ED8D006-F706-4D23-88ED-E11ED28**** 请求ID。 AuthorizationRuleIds List of String [ccrule-1234...

ConfluentSftpsinkconnector返回“FailedtoopennewSFTPchannelwithexistingsession”。 -相关内容

MongoDB CDC

order_customer_id bigint, order_status varchar, order_update_time varchar, PRIMARY KEY (_id) NOT ENFORCED --必须定义主键。) WITH ( 'connector' = 'mongodb-cdc', 'hosts' = 'localhost:2... copy.existing.queue.size 否 10240 Integer 复制数据时要使用的队列的最大大小。 batch.size 否 1024 Integer 游标批量大小(cursor batch size),指在执行查询时,MongoDB 每次返回的文档数量。 poll.m...

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

产品体验

体验中心

云服务器特惠

云服务器
云服务器ECS新人特惠
立即抢购

白皮书

一图详解大模型
浓缩大模型架构,厘清生产和应用链路关系
立即获取

最新活动

爆款1核2G共享型服务器

首年60元,每月仅需5元,限量秒杀
立即抢购

火山引擎增长体验专区

丰富能力激励企业快速增长
查看详情

数据智能VeDI

易用的高性能大数据产品家族
了解详情

一键开启云上增长新空间

立即咨询