Flink MySQL和MySQL-CDC连接器的区别是什么？ [英] Difference between Flink mysql and mysql-cdc connector?

问题描述

为了丰富数据流，我们计划将MySQL(MemSQL)服务器连接到现有的Flink流应用程序

我们可以看到，Flink提供了一个带有JDBC连接器的表APIhttps://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/

此外，我还发现了另一个名为Flink-CDChttps://ververica.github.io/flink-cdc-connectors/master/content/about.html的MySQL连接器，它允许以流方式使用外部数据库

它们之间有什么不同？ 对于我的情况，选择哪一个更好？

推荐答案

变更数据捕获(Cdc)连接器捕获一个或多个表中发生的所有更改。模式通常有一条BEFORE和一条AFTER记录。Flink CDC连接器可以在Flink中以无界模式(流)直接使用，中间不需要Kafka之类的东西。

普通JDBC连接器可以在有界模式下使用，也可以用作查找表。

如果您希望丰富现有的流，您很可能希望使用查找功能。这允许您在表中查询特定键(来自您的流)，并用表中的数据丰富流。请记住，从性能角度来看，最好使用时态表联接。请参阅https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/#how-to-create-a-jdbc-table

中的示例

这篇关于Flink MySQL和MySQL-CDC连接器的区别是什么？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！