AWS Kinesis and Apache Flink Example
Need an environment file to run, recreate .env
from .env.example
and put relevant credentials and you're good to go.
aws kinesis put-record --stream-name <yourCreatedStreamNameHere> --data '{"hello":"test"}' --partition-key "KEY0"
If you're using aws-cli v2
then have to add this to config (~/.aws/config
).
cli_binary_format=raw-in-base64-out
Just run the code. And then run the producer.