A native Node.js producer and consumer library for Amazon Kinesis Data Streams

Build a real-time recommendation engine for an e-commerce website leveraging SageMaker Feature Store as a core component of the solution.

Sample code for the AWS Big Data Blog Post Building a scalable streaming data processor with Amazon Kinesis Data Streams on AWS Fargate

Stream Processing Example using Spring Boot, Spring Cloud Stream, EKS, Kinesis Data Streams, Kinesis Data Analytics

Terraform module and Lambda for Kinesis to Elasticsearch Service logs transfer

Terraform module and Lambda for Kinesis to S3 logs transfer

Autoscaling solution for Kinesis data streams

Terraform module and Lambda for forwarding JSON logs from one Kinesis stream to another.

An example that demonstrates real-time replication of data between Kinesis Data Streams in two regions, using Lambda Enhanced Fan-Out and checkpointing for observability and easy disaster recovery facilitation

This repository contains Kinesis data stream java KCL 2.0x consumer application.

This repo contains a utility to manage Kinesis Data Streams in AWS, as well as a sample stream producer and consumer. [DOCUMENTED]

Using DynamoDb Stream to capture item-level changes in the DynamoDb table, then use kinesis data stream and kinesis firehose to save the changes into a s3 bucket.

Terraform module and Lambda for sending logs from Kinesis to Fluent endpoint.

A Python library of useful utilities for Amazon Kinesis

A tool for counting Kinesis Data Stream data with JSON

Serverless Data pipeline with Api Gateway, AWS lambda, Amazon Kinesis, S3 and Snoflake

Module for creating AWS Data Streams to stream logs from CloudWatch Log Groups. • This repository is defined and managed in Terraform