I need to publish the event using CDC whenever a file is added to S3, to Apache Flink, from Flink the newly added file has to be read and processed.