背景信息:Flink CDC 是实时数据集成框架的开源代表,具有全增量一体化、无锁读取、并发读取、分布式架构等技术优势,在开源社区中非常受欢迎。

为促进 Flink CDC 技术的交流和发展,社区于 5 月 21 日在线举办“Flink CDC Meetup”,邀请众多大咖分享 Flink CDC 在各场景中的最佳实践、生产经验、技术原理等。

5月21日,XTransfer技术专家孙家宝参与“Flink CDC Meetup”线上直播活动,并作为Flink CDC Maintainer成员分享了《MongoDB CDC Connector的实现原理和使用实践》。

XTransfer专注于B2B跨境金融和风控服务。由于B2B类跨境支付场景涉及更为复杂的业务链路,从询盘到最终成交涉及资金流、信息流、物流等条款,需要在每个节点上做好风险管控,这对 XTransfer 的数据处理安全性和准确性都提出了极高的要求。

在业务初期,XTransfer选择了传统的离线数仓架构,采用全量采集、批量处理、覆盖写入的数据集成方式。随着业务的发展,离线数仓越来越不能满足对数据时效性的要求,开始从离线数仓向实时数仓进行演进。

XTransfer大数据风控基础设施架构

有赖于Flink 强大的实时计算能力和丰富的外部系统接入能力,目前,XTransfer已基于Flink搭建了大数据风控基础设施架构,能够保障在跨境B2B全链路上,数据可以被有效的采集、加工和计算,并满足高安全、低延迟、高精度的需求。

同时作为Flink CDC在跨境金融和风控服务领域的最佳实践,XTransfer在 Flink CDC 基础上通过 MongoDB Change Streams 特性实现了 Flink MongoDB CDC Connector,并已贡献给 Flink CDC 社区。

由XTransfer技术团队贡献的MongoDB CDC Connector支持从 MongoDB 数据库获取全量历史数据和增量变更数据。借助 Flink 的集成能力,用户可以非常方便地将 MongoDB 中的数据实时同步到 Flink 支持的所有下游存储。

从开源中受益,并力所能及地反哺社区,是 XTransfer 技术团队所遵循的原则。目前,XTransfer 技术团队正在关注包括Flink在内多个领域的社区建设,接下来,XTransfer 将持续与社区保持互动,继续为社区发展做出贡献。

招聘链接:https://mp.weixin.qq.com/s/G2lppzUyQGhKyH0DUh8_ug

XTransfer技术专家亮相Flink CDC Meetup相关推荐

  1. Flink CDC MongoDB Connector 的实现原理和使用实践

    本文整理自 XTransfer 资深 Java 开发工程师.Flink CDC Maintainer 孙家宝在 Flink CDC Meetup 的演讲.主要内容包括: MongoDB Change ...

  2. Flink CDC + OceanBase 全增量一体化数据集成方案

    本文整理自 OceanBase 技术专家王赫(川粉)在 5 月 21 日 Flink CDC Meetup 的演讲.主要内容包括: OceanBase 介绍 Flink CDC OceanBase C ...

  3. Flink CDC + Hudi 海量数据入湖在顺丰的实践

    摘要:本文整理自顺丰大数据研发工程师覃立辉在 5月 21 日 Flink CDC Meetup 的演讲.主要内容包括: 顺丰数据集成背景 Flink CDC 实践问题与优化 未来规划 Tips:点击「 ...

  4. 阿里、京东、去哪儿等大厂技术专家齐聚北京,Flink China Meetup再度归来!

    某入行不到半年的 Java 程序员问:程序员,为什么要了解/学习新技术? 1.危机感.你不知道什么时候你所掌握的技术就会被淘汰了,可能 5 年.可能 2 年-- 2.提高效率.新技术的出现往往是为了解 ...

  5. Flink CDC 2.0 正式发布,详解核心改进

    简介:Flink CDC 2.0.0 版本于 8 月 10 日正式发布,点击了解详情- 本文由社区志愿者陈政羽整理,内容来源自阿里巴巴高级开发工程师徐榜江 (雪尽) 7 月 10 日在北京站 Flin ...

  6. Flink CDC 系列 - Flink CDC 如何简化实时数据入湖入仓

    摘要:本文整理自伍翀 (云邪).徐榜江 (雪尽) 在 Flink Forward Asia 2021 的分享,该分享以 5 个章节详细介绍如何使用 Flink CDC 来简化实时数据的入湖入仓, 文章 ...

  7. Flink CDC 2.x 让一切变得美好

    本文基于阿里巴巴高级开发工程师徐榜江 (雪尽) 7 月 10 日在北京站 Flink Meetup 分享的<详解 Flink-CDC>整理. <详解 Flink-CDC>深入讲 ...

  8. Flink CDC 在京东的探索与实践

    摘要:本文整理自京东资深技术专家韩飞,在 Flink Forward Asia 2022 数据集成专场的分享.本篇内容主要分为四个部分: 京东自研 CDC 介绍 京东场景的 Flink CDC 优化 ...

  9. Flink原理解析50篇(四)-基于 Flink CDC 打通数据实时入湖

    在构建实时数仓的过程中,如何快速.正确的同步业务数据是最先面临的问题,本文主要讨论一下如何使用实时处理引擎Flink和数据湖Apache Iceberg两种技术,来解决业务数据实时入湖相关的问题. 0 ...

最新文章

  1. PaddleClas
  2. 【网络协议】TCP分段与IP分片
  3. test index.php,index.php
  4. 【转】asp.net中的WebApplication(web应用程序)和WebSite(网站)
  5. 物联网安防技术融合在细分领域的应用分析
  6. 如何让计算机两个用户使用不同步,如何实现两台或多台电脑远程修改文件同步更新?...
  7. .$nextTick 延迟回调
  8. python命令行进入帮助模式_Python 命令行之旅:深入 click 之选项篇
  9. 多线程上下文切换优化与注意
  10. 面试算法题不会做?看这个就够了!
  11. PySpark : Structured Streaming
  12. ajax跨域支持post,支持post请求的js跨域方法汇总
  13. curl命令操作ElasticSearch
  14. 斯坦福NLP名课带学详解 | CS224n 第17讲 - 多任务学习(以问答系统为例)(NLP通关指南·完结)
  15. 编程技巧│使用 python 操作手机 app 超详细步骤
  16. 阿ken的HTML、CSS的学习笔记_浮动与定位(笔记六)
  17. apicloud影视解析APP源码 HTML
  18. 微软提前发新版音乐播放器 阻击苹果新iPod
  19. 吕鑫老师c++资源百度云链接
  20. 成都奔驰电动折叠后视镜改装电耳 蔚一名车汇

热门文章

  1. 2019.08.12【NOIP提高组】模拟 B 组 模拟+DP+差分约束、spfa
  2. 新疆自治区谷歌地球高程DEM等高线下载
  3. [jzoj 1273] 袁绍的刁难 {推理}
  4. 【糗事】ADSL 连接时出现815错误
  5. llmp重启mysql_LNMP使用中mysql宕机挂掉后自动重启脚本 - 老牛博客
  6. 原生JS写《像素鸟》的小游戏(下落的小鸟)
  7. DHTML乌托邦:使用JavaScript和DOM的现代Web设计
  8. 微型计算机的性能主要取决于什么,微型计算机的性能主要取决于什么?
  9. 【秋招备战计划第一弹】今天就开始备战秋招
  10. 东方快车谋杀案 - 笔记