flink mongodb sink自定义开发(支持flink sql)_mongosink需要引入什么jar包-CSDN博客

网站介绍:文章浏览阅读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包