flink-sql-connector-mongodb-cdc和flink-connector-mongodb-cdc的区别是什么
发布时间 2023-07-31 14:56:18作者: zjb480
flink-sql-connector-mongodb-cdc 和 flink-connector-mongodb-cdc 都是 Flink 的 MongoDB CDC（Change Data Capture）连接器，用于从 MongoDB 数据库中捕获变化数据并将其传递给 Flink 进行实时处理。 它们的区别在于使用方式和集成方式： 1. flink-sql-connector-mongodb-cdc ：这是一个基于 Flink SQL 的连接器，允许您使用 SQL 查询语句来捕获 MongoDB 数据库中的变化数据。您可以使用 Flink SQL 的语法来定义源表、目标表以及变化数据的处理逻辑。这个连接器提供了更高层次的抽象，使得使用 SQL 进行 MongoDB CDC 更加方便。 2. flink-connector-mongodb-cdc ：这是一个基于 Flink 的连接器，使用 Flink DataStream API 来捕获 MongoDB 数据库中的变化数据。您可以使用 DataStream API 来定义源和目标以及处理逻辑。这个连接器提供了更灵活的编程方式，适用于那些更喜欢使用编程接口而不是 SQL 的用户。 总结来说， flink-sql-connector-mongodb-cdc 提供了使用 SQL 进行 MongoDB CDC 的高级抽象，而 flink-connector-mongodb-cdc 则提供了更灵活的编程接口。您可以根据自己的喜好和需求选择适合的连接器