>我司基于最新提供流批一体的接口,实现了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连接器? > >这个可以自已定义一个,参考源码写一个,自己写出来的才是自己的,直接用别人的还是别人的 > > > > >------------------ 原始邮件 ------------------ >发件人: > "user-zh" > ><casel_c...@126.com>; >发送时间: 2021年9月17日(星期五) 下午4:39 >收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>; > >主题: Flink SQL官方何时能支持redis和mongodb连接器? > > > >redis和mongodb经常在工作中用到,但Flink官方一直没有提供这两个标准连接器,想问一下什么时候能正式release方便大家使用呢? >ps: behair库已经很久没更新了,对应的flink版本太低。