This pattern will connect Kinesis data streams together with EventBridge Pipes. The source stream is filtered into multiple Kinesis streams downstream.
Kinesis stream is configured as the pipe source, and filters are created to filter records to downstream kinesis streams. This pattern allows you to filter kinesis streams into other kinesis streams.
How the pattern works
EventBridge Pipes is used to filter records from the source Kinesis stream into downstream consumers. Records are base64 encoded in Kinesis and EventBridge Pipes decodes the message and supports filtering on the payload of the message.
< Back to all patterns
Clone repo
git clone https://github.com/aws-samples/serverless-patterns/cd serverless-patterns/eventbridge-pipes-kinesis-to-kinesis-with-filteringDeploy
sam deploy --guidedTesting
See the README in the GitHub repo for detailed testing instructions.
Cleanup
Delete the stack:
sam delete.Created by:
