GitHub repository: kigster/kinsumer
Primary language: Ruby
Description: Kinsumer — is a Kinesis Stream Processing library, that attaches to an AWS Kinesis stream for reading messages, concurrently from each shard. The gem uses Celluloid for concurrency, and AWS SDK V2 for dequeuing messages from the stream. Local state is maintained using Redis.