>我司基于最新提供流批一体的接口,实现了mongodb的连接器,支持source和sink,实现了控制批量插入频率、控制缓存批的数据量和mongo文档对象和java对象转换,同时还可选择批量更新,并且使用的mongo最新异步驱动,后期我还会不断优化性能,看大佬能否推动一下,把这个连接器贡献给社区


问一下自己开发的连接器要怎么添加到 https://flink-packages.org/ 网站给大家搜索到?这位朋友能够将你们的连接器贡献上去呢?

















在 2021-09-23 09:32:39,"2572805166" <2572805...@qq.com.INVALID> 写道:
>我司基于最新提供流批一体的接口,实现了mongodb的连接器,支持source和sink,实现了控制批量插入频率、控制缓存批的数据量和mongo文档对象和java对象转换,同时还可选择批量更新,并且使用的mongo最新异步驱动,后期我还会不断优化性能,看大佬能否推动一下,把这个连接器贡献给社区
>
>
>------------------ 原始邮件 ------------------
>发件人: "Yun Tang";
>发件时间: 2021-09-22 10:55
>收件人: "user-zh@flink.apache.org";
>主题: Re: 回复:Flink SQL官方何时能支持redis和mongodb连接器?
>
>
>
>Hi,
>
>其实目前Flink社区并不是那么欢迎新增官方支持的connector,主要原因就是社区的开发人员有限,没有精力维护太多的connector,尤其是一些connector的实现需要一定的相关背景,但很难保证review代码的开发人员具有相关背景,毕竟大家都需要为自己approve的代码负责。
>你可以在 flink-packages [1] 里面找一下,或者考虑自己实现并维护(基础实现应该是复杂度不高的)。
>
>
>[1] https://flink-packages.org/
>
>
>祝好
>唐云
>
>________________________________
>From: 黑色 
>Sent: Saturday, September 18, 2021 17:17
>To: user-zh@flink.apache.org 
>Subject: 回复:Flink SQL官方何时能支持redis和mongodb连接器?
>
>这个可以自已定义一个,参考源码写一个,自己写出来的才是自己的,直接用别人的还是别人的
>
>
>
>
>------------------&nbsp;原始邮件&nbsp;------------------
>发件人:                                                                           
>                                             "user-zh"                         
>                                                           
><casel_c...@126.com&gt;;
>发送时间:&nbsp;2021年9月17日(星期五) 下午4:39
>收件人:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;
>
>主题:&nbsp;Flink SQL官方何时能支持redis和mongodb连接器?
>
>
>
>redis和mongodb经常在工作中用到,但Flink官方一直没有提供这两个标准连接器,想问一下什么时候能正式release方便大家使用呢?
>ps: behair库已经很久没更新了,对应的flink版本太低。

回复