如何构建批流一体数据融合平台的一致性语义保证？( 七 )
DataPipeline 选择 MQ 模式，主要有几点考虑：
第一，在我们产品应用中有一个非常常见的场景：要做数据的一对多分发。数据要进行一次读取，然后分发到各种不同的目的地，这是一个非常适合消息队列使用的分发模型。
第二，有时会对一次读取的数据加不同的处理逻辑，我们希望这种处理不要重新对源端产生一次读取。所以在多数情况下，都需将数据先读到消息队列，然后再配置相应的处理逻辑。
第三，Kafka Connect 就是基于 MQ 模式的，它有大量的开源连接器。基于 Kafka Connect 框架，我们可以重用这些连接器，节省研发的投入。
第四，当你把数据抽取跟写入目的地，从处理逻辑中独立出来之后，便可以提供更强大的集成能力。因为你可以在消息队列上集成更多的处理逻辑，而无需考虑重新写整个 Job。
相应而言，如果你选择将 MQ 作为所有 JOB 的传输通道，就必须要克服几个缺点：
推荐阅读
- 小鱼人|如何在新赛季稳定上分？善于抓失误的小鱼人，值得认真练上一波
- 阴阳师|阴阳师SR川猿强度如何 是否值得抽卡 改变斗技环境 大佬的新玩具
- 手机游戏|梦幻西游手游：活力如何换金币 一切都已给出 就看你的选择
- 华佗|三国杀：两位\奶爸\，朱治与华佗比，强度如何呢？
- 亲朋上分|《亲朋上分》266391亲朋下分亲朋上下分永劫无间崔三娘技能介绍 崔三娘如何获得更多技能
- s6|金铲铲之战：S6双城传说如何才能快速上手？基础知识很关键
- |冰雪传奇：平民玩家四转后如何打金
- 穿越火线|CF：传说武器再度上新，那王者、炫金该如何发展？
- 打野|打野已经被削到几乎不能再削了，到底如何平衡打野位置？
- 电子竞技|新华社对话明凯、阿布，探讨电竞选手是如何炼成的？宁王无辜躺枪