Webinar: Get Hands-On With ServerlessRegister now

Apache Flink with Amazon Kinesis Data Stream Source and Amazon Data Firehose Sink

Apache Flink → Amazon Kinesis Data Streams → Amazon Kinesis Firehose

Create a Managed Service for Apache Flink application with an Amazon Kinesis Data Stream source and Amazon Kinesis Firehose sink.

This sample project demonstrates how to use Managed Service for Apache Flink to consume a Kinesis Data Stream and produce to a Firehose sink.
Managed Service for Apache Flink provides the underlying infrastructure for your Apache Flink applications. It handles core capabilities like provisioning compute resources, parallel computation, automatic scaling, and application backups (implemented as checkpoints and snapshots).

< Back to all patterns
Language:
TypeScript
Framework:
AWS CDK

GitHub icon Download this pattern (.zip)

GitHub icon View this pattern on GitHub

Clone repo

git clone https://github.com/aws-samples/serverless-patterns/cd serverless-patterns/cdk-kinesis-flink-firehose

Deploy

cdk deploy

Testing

See the README in the GitHub repo for detailed testing instructions.

Cleanup

cdk destroy

Additional resources

Created by:

Jim Thwaits

Jim Thwaits

Cloud Application Architect, AWS

Follow on LinkedIn