https://github.com/ververica/flink-cdc-connectors/issues/1036
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
针对您提及的GitHub问题链接https://github.com/ververica/flink-cdc-connectors/issues/1036,虽然具体问题内容未在给定的知识库资料中直接展示,但根据提供的参考资料,我可以帮助解答关于阿里云实时计算Flink版中使用社区版CDC连接器的一般性问题及配置指导,并强调几个关键步骤和注意事项:
factoryIdentifier()
方法返回的字符串值,以自定义连接器名称,如sqlserver-cdc-test
。flink-sql-connector-sqlserver-cdc
子模块进行编译并打包成JAR文件。sqlserver-cdc-test
)作为connector
参数使用。.hosts("mongo.example.com:27017")
等方法链配置MongoDB连接信息、认证凭据、监控的数据库和集合等。注意根据是否需要增量快照功能选择正确的MongoDBSource.builder()
方法所在包。flink-connector-mongodb
依赖到您的项目中以使用该连接器。java.io.EOFException: SSL peer shut down incorrectly
报错,尝试在MySQL CDC表的WITH参数中设置'jdbc.properties.useSSL'='false'
,或对于维表配置,URL中加入&useSSL=false
。请根据实际遇到的问题,参考上述指南调整配置或采取相应的解决措施。如果问题仍未解决,建议直接查看问题链接中的讨论或在相关社区寻求帮助。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。
你好,我是AI助理
可以解答问题、推荐解决方案等