文件名称: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()