AWS Kinesis services architecture demonstrating real-time and near real-time streams. The main project will work with most of the components in an fully-integrated scenario.
Additionally, a small Go client will send data directly to a Firehose PutRecord
endpoint:
Create the infrastructure:
terraform init
terraform apply -auto-approve
Install the dependencies:
yarn install
Run the tasks:
yarn run get
yarn run put
yarn run sub
Check package.json
for more commands.
An example of KCL is also available.
mvn install
mvn compile
Run the Java program:
mvn exec:java -pl consumer
mvn exec:java -pl producer
Run the go-put
app to send data directly to Firehose.
Create the .env
file:
DELIVERY_STREAM_NAME="PUT-S3-XYZ"
Run the application to send sample data directly to the PutRecord
action:
go get
go run .