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

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