Amazon S3 作为使用 CDC 的 Apache Flink 的源

Question

每当将文件添加到 S3、Apache Flink 时，我都需要使用 CDC 发布事件，必须从 Flink 读取并处理新添加的文件。

Answer 1

当 S3 存储桶中发生 s3:ObjectCreated:* 事件时，您可以收到通知，像

io.debezium.connector.mysql.MySqlStreamingChangeEventSource

一样实现您自己的数据源，然后处理它。