如何使用javaflinkjob从ibmcos读取数据并将其推送到kafka/eventstreams

3bygqnnd  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(184)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题