我创建了一个javaflink作业，它从一个主题（kafka）读取数据，并将数据推送到另一个主题（kafka）。
但是现在我想从ibmcos中可用的文件中读取数据，并将其推送到topic（kafka）中。
我发现了一些和s3桶有关的东西：https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/aws.html
我试过了，但没什么用。