我创建了一个javaflink作业,它从一个主题(kafka)读取数据,并将数据推送到另一个主题(kafka)。
但是现在我想从ibmcos中可用的文件中读取数据,并将其推送到topic(kafka)中。
我发现了一些和s3桶有关的东西:https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/aws.html
我试过了,但没什么用。
我创建了一个javaflink作业,它从一个主题(kafka)读取数据,并将数据推送到另一个主题(kafka)。
但是现在我想从ibmcos中可用的文件中读取数据,并将其推送到topic(kafka)中。
我发现了一些和s3桶有关的东西:https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/aws.html
我试过了,但没什么用。
暂无答案!
目前还没有任何答案,快来回答吧!