kinesis-flink-hello-world:AWS Kinesis和Apache Flink示例

时间:2024-03-28 23:24:58
【文件属性】:

文件名称:kinesis-flink-hello-world:AWS Kinesis和Apache Flink示例

文件大小:61KB

文件格式:ZIP

更新时间:2024-03-28 23:24:58

java aws-cli aws-kinesis apache-flink Java

kinesis-flink-hello-world AWS Kinesis和Apache Flink示例 动因制片人 aws kinesis put-record --stream-name < yourCreatedStreamNameHere> --data ' {"hello":"test"} ' --partition-key " KEY0 " 免责声明 如果您使用的是aws v2则必须将其添加到config( ~/.aws/config )中。 cli_binary_format=raw-in-base64-out Flink消费者 只需运行代码。 然后运行生产者。


【文件预览】:
kinesis-flink-hello-world-main
----.gitignore(1KB)
----settings.gradle(27B)
----build.gradle(1006B)
----src()
--------main()
----gradlew(6KB)
----README.md(420B)
----gradlew.bat(3KB)
----gradle()
--------wrapper()

网友评论