Kinesis Connector for Structured Streaming

ZIO-based AWS Kinesis client for Scala

A comprehensive Scala library for Kinesis

This project aims at doing performance testing of AWS Kinesis stream

Writes Snowplow enriched events from Kinesis to Elasticsearch

Scala based wrapper for Kinesis Consumer Library which exposes the stream as an Akka Streams Source

Spark Streaming Examples

haystack component that collects spans from various sources and publish to kafka

pekko-kinesis supports Pekko commponets for AWS Kinesis.

A 'cost effective' way to download files

Example 'Kinesis Analytics for Java Application'

An Akka actorbased collector that publishes collected events to AWS Kinesis

Scala application to stream from AWS Kinesis stream to AWS Aurora RDS

FS2 bindings for the Kinesis Producer Library

Lollypop is a multiparadigm scripting language for the JVM featuring declarative/SQL, functional and reactive programming models.

Event Driven Kinesis AWS Bucket Dumper

scalatest eventstream testing

Real-time data transformations in Spark. Conjunction with AWS kinesis.

A Scala AWS Kinesis Splunk project