Request a Demo

Sqs2kinesis 0.1.0 released

Announcements New releases
#1

First non-rc release of sqs2kinesis.

The application (sqs2kinesis) is used to read messages from the SQS queue and send them to the Kinesis stream using a back-pressured mechanism.

The application.conf file is used to set it up:

sqs2kinesis {
    sqs-queue = {sqs-queue-url}
    kinesis-stream-name = {kinesis-stream-name}
}

This is a Scala application, so you could either run it via java -jar or using docker.

The docker image is here

2 Likes