网站介绍:文章浏览阅读3.9k次。flink mongodb sink自定义开发1. 背景目前官方关于自定义sink source资料较少,示例代码少,幸好github有一个clickhouse的自定义sink可以借鉴https://github.com/gmmstrive/flink-connector-clickhouse2. 步骤1. 环境jdk8idea 2020scala 2.112. pom以下是自定义connector开发时可以参考的pom文件<packaging>jar</_mongosink需要引入什么jar包
- 链接地址:https://blog.csdn.net/xiaohu21/article/details/113487253
- 链接标题:flink mongodb sink自定义开发(支持flink sql)_mongosink需要引入什么jar包-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:576
- 网站标签:mongosink需要引入什么jar包